Struct LifecycleLedger 

pub struct LifecycleLedger { /* private fields */ }

Source of truth from admission through completion publication.

Implementations

impl LifecycleLedger

pub fn new() -> Self

Empty ledger.

pub fn len(&self) -> usize

Number of entries.

pub fn is_empty(&self) -> bool

Whether empty.

pub fn transaction_ids(&self) -> Vec<TransactionId>

Snapshot of all transaction ids (for shutdown).

pub fn get(&self, id: &TransactionId) -> Option<&LedgerEntry>

Lookup by id.

pub fn get_mut(&mut self, id: &TransactionId) -> Option<&mut LedgerEntry>

Mutable lookup by id.

pub fn session_active(&self, key: &SessionKey) -> bool

Whether a session key is already active.

pub fn transaction_for_session(&self, key: &SessionKey) -> Option<TransactionId>

Resolve the active transaction for a session key.

pub fn distinct_sessions_on_channel(&self, channel: &ChannelId) -> usize

Count distinct active sessions on a channel (D-015 / ChannelLimits).

pub fn insert_queued( &mut self, entry: LedgerEntry, max_distinct_sessions: Option<usize>, ) -> Result<(), LedgerInsertError>

Insert a complete Queued entry. Returns Err if id or session collides or if max_distinct_sessions would be exceeded for a new SessionKey.

pub fn remove(&mut self, id: &TransactionId) -> Option<LedgerEntry>

Remove an entry and drop its reservations (via Drop).

pub fn bind_session( &mut self, id: &TransactionId, key: SessionKey, max_distinct_sessions: Option<usize>, ) -> Result<(), LedgerInsertError>

Bind session key after external session claim (supervisor only).

When max_distinct_sessions is Some, a net-new session on the channel that would exceed the bound fails with DistinctSessionsExceeded. Replacing an existing key on the same channel does not consume an extra distinct slot.

Trait Implementations

impl Debug for LifecycleLedger

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

Formats the value using the given formatter.

impl Default for LifecycleLedger

fn default() -> LifecycleLedger

Returns the “default value” for a type.