Class WeatherSourceRegistry

java.lang.Object

ecmwf.ecpds.master.weather.WeatherSourceRegistry

public final class WeatherSourceRegistry
extends Object

Bounded source discovery. Only the Master supplies subscribe-authenticated callback registrations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WeatherSourceRegistry.Probe
static final record	WeatherSourceRegistry.Status
static final record	WeatherSourceRegistry.Timing
static final class	WeatherSourceRegistry.UnavailableException	Temporary loss of registration or verification capacity must not permanently retire source evidence.

Constructor Summary

Constructors

Constructor	Description
WeatherSourceRegistry()
WeatherSourceRegistry(LongSupplier nanoTime)
WeatherSourceRegistry(LongSupplier nanoTime, LongSupplier wallTime)

Method Summary

Modifier and Type	Method	Description
void	close()
void	poll(Set<String> selected, Map<String,?> registrations, WeatherSourceRegistry.Probe probe)	One callback at most; no network calls or cryptography while holding the registry monitor.
boolean	registered(String source)
List<WeatherSourceRegistry.Status>	snapshot()
WeatherSourceRegistry.Timing	verify(WeatherBatch batch, Object currentRegistration)	A shared REST signature or a matching source name cannot supply the registered public key.

Methods inherited from class Object

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

Constructor Details

WeatherSourceRegistry

public WeatherSourceRegistry()

WeatherSourceRegistry

public WeatherSourceRegistry(LongSupplier nanoTime)

WeatherSourceRegistry

public WeatherSourceRegistry(LongSupplier nanoTime,
 LongSupplier wallTime)

Method Details

poll

public void poll(Set<String> selected,
 Map<String,?> registrations,
 WeatherSourceRegistry.Probe probe)
          throws Exception

One callback at most; no network calls or cryptography while holding the registry monitor.

Throws:

Exception

snapshot

public List<WeatherSourceRegistry.Status> snapshot()

verify

public WeatherSourceRegistry.Timing verify(WeatherBatch batch,
 Object currentRegistration)
                                    throws IOException,
GeneralSecurityException

A shared REST signature or a matching source name cannot supply the registered public key.

Throws:

IOException

GeneralSecurityException

registered

public boolean registered(String source)

close

public void close()