Class WeatherCollector

java.lang.Object

ecmwf.ecpds.master.weather.WeatherCollector

public final class WeatherCollector
extends Object

Bounded, volatile aggregation. Transport must authenticate source identity and enforce encoded batch limits before calling this collector.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	WeatherCollector.Snapshot
static final record	WeatherCollector.Summary

Constructor Summary

Constructors

Constructor	Description
WeatherCollector()
WeatherCollector(Clock clock)

Method Summary

Modifier and Type	Method	Description
WeatherReceipt	accept(UUID expectedEpoch, Set<String> authorizedSources, WeatherObservation observation, long queueAgeMs, long measuredClockOffsetMs)	The caller supplies authenticated scope and measured transport age/offset; these are not trusted fields taken from the observation payload.
WeatherSelection	configure(long expectedRevision, boolean enabled, Set<WeatherObservation.Path> paths)
WeatherSelection	selection()
WeatherCollector.Snapshot	snapshot()
List<WeatherViewer.Path>	viewer(Set<String> hosts, Set<String> destinations, boolean full)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WeatherCollector

public WeatherCollector()

WeatherCollector

public WeatherCollector(Clock clock)

Method Details

selection

public WeatherSelection selection()

configure

public WeatherSelection configure(long expectedRevision,
 boolean enabled,
 Set<WeatherObservation.Path> paths)

accept

public WeatherReceipt accept(UUID expectedEpoch,
 Set<String> authorizedSources,
 WeatherObservation observation,
 long queueAgeMs,
 long measuredClockOffsetMs)

The caller supplies authenticated scope and measured transport age/offset; these are not trusted fields taken from the observation payload.

snapshot

public WeatherCollector.Snapshot snapshot()

viewer

public List<WeatherViewer.Path> viewer(Set<String> hosts,
 Set<String> destinations,
 boolean full)