Skip to main content

Module seq_store

Module seq_store 

Source
Expand description

Pluggable sequence-number store.

FIX requires both peers to maintain a strictly increasing outbound MsgSeqNum and to track the highest inbound sequence number they have processed, so that a reconnect can detect gaps and issue / honour a ResendRequest. FixSeqStore abstracts that persistence point.

InMemorySeqStore is the default, test-friendly implementation backed by atomics. A durable implementation (for example one backed by atomr-persistence) only needs to implement the same four async methods; the session layer interacts with the store exclusively through this trait, so swapping in a crash-safe store requires no changes to the FSM. We deliberately keep atomr-persistence out of this crate’s dependency tree — this trait is the integration point.

Structs§

InMemorySeqStore
In-memory FixSeqStore backed by atomics. Counters start at 1, matching the FIX convention that the first message of a session carries MsgSeqNum=1.

Traits§

FixSeqStore
Persistence for the two sequence counters a FIX session must keep.