Struct Sequencer 

pub struct Sequencer { /* private fields */ }

Used by sender to track the message sequence numbers it sends to each destination. Each Sequencer object has a session id, sequence numbers are scoped by the (session_id, SeqKey) pair.

Implementations

impl Sequencer

pub fn assign_seq(&self, port_id: &PortAddr) -> SeqInfo

Assign the next seq for a port, mutate the sequencer with the new seq, and return the new seq.

• Handler ports: share the same sequence scheme per actor (keyed by ActorAddr).
• Ephemeral ports: get individual sequence schemes (keyed by PortAddr).
• Control ports: bypass receive-side reordering and use SeqInfo::Direct.

pub fn last_sent(&self, port_id: &PortAddr) -> Option<u64>

Last sequence sent to port_id.

pub fn last_sent_to_actor(&self, actor: &ActorAddr) -> u64

Last sequence sent to any handler port on actor.

pub fn assign_seqs(&self, keys: &[SeqKey]) -> Vec<(Range<usize>, u64)>

Assign the next sequence number to each key.

This assigns the same sequence numbers, in the same order, as calling Self::assign_seq for each equivalent destination. Each occurrence of a repeated key advances its sequence number.

The result is run-length encoded. Each (range, seq) assigns seq to the input indexes in range. The ordered ranges cover 0..keys.len() without gaps. An empty input returns an empty result.

pub fn session_id(&self) -> Uuid

Id of the session this sequencer belongs to.

Trait Implementations

impl Clone for Sequencer

fn clone(&self) -> Sequencer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Sequencer

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

Formats the value using the given formatter.