Struct CursorProgressFacts 

pub struct CursorProgressFacts { /* private fields */ }

Variable participant-scoped cursor facts; no fixed occurrence array exists.

Implementations

impl CursorProgressFacts

pub const fn new() -> Self

Creates an empty participant-scoped fact map.

pub fn record(&mut self, key: CursorProgressKey) -> bool

Inserts an independently fireable (participant_index, boundary) fact.

Returns true only when the exact pair was not already present.

pub fn consume_through( &mut self, participant_index: ParticipantIndex, through: DeliverySeq, ) -> Vec<CursorProgressKey>

Marks every pending boundary at or below through consumed for one participant, without touching another participant’s identical boundary.

pub fn get(&self, key: CursorProgressKey) -> Option<CursorProgressFact>

Returns one exact fact state.

pub fn len(&self) -> usize

Number of distinct participant/boundary pairs.

pub fn is_empty(&self) -> bool

Returns whether no cursor fact exists.

pub fn encode(&self) -> Result<Vec<u8>, CursorFactEncodeError>

Deterministically serializes the variable map in key order.

Format: count:u32, followed by participant_index:u64, boundary:u64, and state:u8 (0 Pending, 1 Consumed) per fact. This is lifecycle storage, not the participant network frame format.

Errors

Returns CursorFactEncodeError if count or allocation length cannot be represented.

Trait Implementations

impl Clone for CursorProgressFacts

fn clone(&self) -> CursorProgressFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CursorProgressFacts

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

Formats the value using the given formatter.

impl Default for CursorProgressFacts

fn default() -> CursorProgressFacts

Returns the “default value” for a type.

impl Eq for CursorProgressFacts

impl PartialEq for CursorProgressFacts

fn eq(&self, other: &CursorProgressFacts) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CursorProgressFacts