Class WeatherOutbox

java.lang.Object

ecmwf.ecpds.master.weather.WeatherOutbox

public final class WeatherOutbox
extends Object

Optional source evidence never waits for a transport worker. Loss counters must be reported by the owning source scheduler.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	WeatherOutbox.Delivery
static final record	WeatherOutbox.Status

Constructor Summary

Constructors

Constructor	Description
WeatherOutbox()
WeatherOutbox(LongSupplier nanoTime)

Method Summary

Modifier and Type	Method	Description
void	acknowledge(WeatherBatch batch, WeatherAcknowledgement acknowledgement)
void	acknowledge(UUID expectedMasterEpoch, List<WeatherReceipt> receipts)
List<WeatherOutbox.Delivery>	batch()	The worker must additionally enforce the actual serialized HTTP/RMI batch size.
void	clear()
boolean	offer(WeatherObservation observation)
Set<UUID>	pendingEventIds()
WeatherOutbox.Status	status()

Methods inherited from class Object

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

Constructor Details

WeatherOutbox

public WeatherOutbox()

WeatherOutbox

public WeatherOutbox(LongSupplier nanoTime)

Method Details

offer

public boolean offer(WeatherObservation observation)

batch

public List<WeatherOutbox.Delivery> batch()

The worker must additionally enforce the actual serialized HTTP/RMI batch size. Reservations below deliberately overestimate the bounded DTO strings.

acknowledge

public void acknowledge(UUID expectedMasterEpoch,
 List<WeatherReceipt> receipts)

status

public WeatherOutbox.Status status()

clear

public void clear()

acknowledge

public void acknowledge(WeatherBatch batch,
 WeatherAcknowledgement acknowledgement)

pendingEventIds

public Set<UUID> pendingEventIds()