Class WeatherAdministration

java.lang.Object

ecmwf.ecpds.master.weather.WeatherAdministration

public final class WeatherAdministration
extends Object

Master-owned control state. Database work is confined to startup and explicit administrator saves; snapshots never query the database.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	WeatherAdministration.Configuration
static final record	WeatherAdministration.Status
static interface	WeatherAdministration.Store

Constructor Summary

Constructors

Constructor	Description
WeatherAdministration(WeatherAdministration.Store store)
WeatherAdministration(WeatherAdministration.Store store, WeatherPersistence persistence, WeatherSourceRegistry sources)

Method Summary

Modifier and Type	Method	Description
WeatherCapabilities	capabilities(String sourceId)
static String	formatPaths(List<WeatherObservation.Path> paths)
void	load()
static Set<WeatherObservation.Path>	parsePaths(String text)
static Set<WeatherObservation.Path>	parsePaths(String text, int maximum)
static Set<WeatherObservation.Path>	parsePaths(String text, int maximum, int maximumBytes)
WeatherPersistence	persistence()
WeatherProbes	probes()
WeatherAcknowledgement	receive(WeatherBatch batch)
WeatherAcknowledgement	receive(WeatherBatch batch, Object currentRegistration)	Ingress verifies signed identity/timing and admits only to bounded in-memory state; database work is background-only.
void	reconcile(Set<WeatherObservation.Path> paths)
void	refreshAvailability()	The owning background scheduler updates readiness; page reads never run database probes.
WeatherAdministration.Status	save(long expectedRevision, Set<WeatherObservation.Path> paths, String actor)
Set<String>	selectedSources()
WeatherAdministration.Status	setCollectionEnabled(long expectedRevision, boolean enabled, String actor)
WeatherSourceRegistry	sources()
WeatherAdministration.Status	status()
WeatherViewer	viewer(Set<String> hosts, Set<String> destinations, boolean full)
boolean	viewerEnabled()
long	viewerRevision()

Methods inherited from class Object

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

Constructor Details

WeatherAdministration

public WeatherAdministration(WeatherAdministration.Store store)

WeatherAdministration

public WeatherAdministration(WeatherAdministration.Store store,
 WeatherPersistence persistence,
 WeatherSourceRegistry sources)

Method Details

probes

public WeatherProbes probes()

reconcile

public void reconcile(Set<WeatherObservation.Path> paths)
               throws Exception

Throws:

Exception

load

public void load()
          throws Exception

Throws:

Exception

save

public WeatherAdministration.Status save(long expectedRevision,
 Set<WeatherObservation.Path> paths,
 String actor)
                                  throws Exception

Throws:

Exception

setCollectionEnabled

public WeatherAdministration.Status setCollectionEnabled(long expectedRevision,
 boolean enabled,
 String actor)
                                                  throws Exception

Throws:

Exception

refreshAvailability

public void refreshAvailability()

The owning background scheduler updates readiness; page reads never run database probes.

persistence

public WeatherPersistence persistence()

viewer

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

viewerEnabled

public boolean viewerEnabled()

viewerRevision

public long viewerRevision()

status

public WeatherAdministration.Status status()

sources

public WeatherSourceRegistry sources()

selectedSources

public Set<String> selectedSources()

capabilities

public WeatherCapabilities capabilities(String sourceId)

receive

public WeatherAcknowledgement receive(WeatherBatch batch)
                               throws IOException

Throws:

IOException

receive

public WeatherAcknowledgement receive(WeatherBatch batch,
 Object currentRegistration)
                               throws IOException

Ingress verifies signed identity/timing and admits only to bounded in-memory state; database work is background-only.

Throws:

IOException

parsePaths

public static Set<WeatherObservation.Path> parsePaths(String text)

parsePaths

public static Set<WeatherObservation.Path> parsePaths(String text,
 int maximum)

parsePaths

public static Set<WeatherObservation.Path> parsePaths(String text,
 int maximum,
 int maximumBytes)

formatPaths

public static String formatPaths(List<WeatherObservation.Path> paths)