Skip to main content

Module stream_seq

Module stream_seq 

Source
Expand description

Per-stream monotonic sequence frontier — durable state for outbound frame stamping and inbound ack tracking.

§Persistence

Each per-stream frontier is persisted under Namespace::Meta with key "sync.stream_seq:{stream_id:016x}". The 16-byte value encodes last_assigned || last_acked as two big-endian u64s.

StreamSeqTracker::load restores all entries on startup so the first outbound frame after a restart continues from where it left off (the persist-before-send invariant is maintained across process restarts).

Structs§

StreamSeqTracker
Tracks the per-stream monotonic sequence frontier for outbound frame stamping and ack recording.