Reclaim a payload while retaining its sequence/metadata tombstone.
Read a sequence, waiting until it arrives, closes, or the deadline passes.
Optionaldeadline: DeadlineRead by ingestion order rather than logical sequence.
Optionaldeadline: DeadlineReturn the declared final sequence, or null while none is known.
Return the node id this log belongs to.
Translate a zero-based arrival position to its logical sequence.
Read the shared logical-sequence cursor, waiting at gaps.
A clean end may append null; use getByArrivalOrder for ingestion order.
Optionaldeadline: DeadlineOptionallimit: numberPersist one fragment and return its assigned sequence number.
Atomically persist a batch and return corresponding sequence numbers.
Return the number of fragment slots currently retained.
Pluggable ordered log behind an A11 node stream.
AsyncNode, ChunkStoreReader, and ChunkStoreWriter depend on this contract rather than a particular database. Implement it to keep an agent's stream data in a durable or distributed backend. Sequence order is the logical order consumed by nodes; arrival order is retained separately so out-of-order network fragments can also be inspected.
A final fragment (
continued === false) establishes the stream's final sequence. Closing writes records producer success/failure and releases waiters, but does not create that final fragment itself.