Expand description
Offline-first store-and-forward buffering for pamoja.
Devices on intermittent links append records while offline and drain them in
order when a link returns, so a node that is disconnected for hours or days
loses nothing. This crate provides durable first-in first-out implementations
of the core Store trait:
MemoryStore- a fast in-memory queue, optionally capacity-bounded so a full queue becomes an explicit backpressure signal.FileStore- a crash-safe on-disk queue that survives power loss, for the power-loss-safe field logging the mission depends on.
Both buffer raw bytes, so an application pairs a Store
with a Codec to persist encoded payloads and
a Transport to forward them when a link appears.
drain_to is the forward half: it publishes buffered records onto a
transport in order, removing each only after it is sent, so a failed link
loses nothing.
Structs§
- File
Store - A durable first-in first-out queue backed by one file per record.
- Memory
Store - A fast in-memory first-in first-out queue.
Functions§
- drain_
to - Drains
storeontotransport, publishing each record totopic, oldest first.