Class WeatherPersistence

java.lang.Object

ecmwf.ecpds.master.weather.WeatherPersistence

All Implemented Interfaces:

AutoCloseable

public final class WeatherPersistence
extends Object
implements AutoCloseable

Single background writer. Admission is memory-only, bounded and nonblocking.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
WeatherPersistence()
WeatherPersistence(WeatherPersistence.Store store)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	offer(WeatherObservation observation)
boolean	ready()
WeatherPersistence.Status	status()
void	step()	Call only from the owning scheduler.

Methods inherited from class Object

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

Constructor Details

WeatherPersistence

public WeatherPersistence(WeatherPersistence.Store store)

WeatherPersistence

public WeatherPersistence()

Method Details

offer

public boolean offer(WeatherObservation observation)

ready

public boolean ready()

step

public void step()

Call only from the owning scheduler. At most ten events/100 connections per second; two retries per event.

status

public WeatherPersistence.Status status()

close

public void close()

Specified by:

close in interface AutoCloseable