Struct SequenceManager 

pub struct SequenceManager { /* private fields */ }

Manages sequence numbers for a FIX session.

Uses atomic operations for thread-safe access without locks.

Implementations

impl SequenceManager

pub fn new() -> SequenceManager

Creates a new sequence manager with sequence numbers starting at 1.

pub fn with_initial(sender_seq: u64, target_seq: u64) -> SequenceManager

Creates a new sequence manager with specified starting values.

Arguments

• sender_seq - Initial sender sequence number
• target_seq - Initial target sequence number

pub fn next_sender_seq(&self) -> SeqNum

Returns the next sender sequence number without incrementing.

pub fn next_target_seq(&self) -> SeqNum

Returns the next target sequence number without incrementing.

pub fn allocate_sender_seq(&self) -> SeqNum

Allocates and returns the next sender sequence number.

This atomically increments the sequence number and returns the value before the increment.

pub fn increment_target_seq(&self)

Increments the target sequence number.

Call this after successfully processing an incoming message.

pub fn set_sender_seq(&self, seq: u64)

Sets the next sender sequence number.

Arguments

• seq - The new sequence number

pub fn set_target_seq(&self, seq: u64)

Sets the next target sequence number.

Arguments

• seq - The new sequence number

pub fn reset(&self)

Resets both sequence numbers to 1.

pub fn validate_incoming(&self, received: u64) -> SequenceResult

Validates an incoming sequence number.

Arguments

• received - The received sequence number

Returns

• Ok(()) if the sequence number matches expected
• Err(SequenceResult::TooLow) if it’s a possible duplicate
• Err(SequenceResult::Gap) if there’s a gap

Trait Implementations

impl Debug for SequenceManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SequenceManager

fn default() -> SequenceManager

Returns the “default value” for a type.