Struct InputLedger 

pub struct InputLedger { /* private fields */ }

In-memory ledger tracking InputState for all inputs.

Implementations

impl InputLedger

pub fn new() -> Self

Create a new empty ledger.

pub fn accept(&mut self, state: InputState)

Accept a new InputState into the ledger.

pub fn accept_with_idempotency( &mut self, state: InputState, key: IdempotencyKey, ) -> Option<InputId>

Accept with an idempotency key for dedup. Returns Some(existing_id) if the key already exists (dedup hit).

pub fn recover(&mut self, state: InputState) -> bool

Recover a durable InputState from persistent storage.

Unlike accept(), this also rebuilds the idempotency index and filters out Ephemeral inputs (which should not survive restart). Returns true if the state was inserted, false if filtered.

pub fn get(&self, input_id: &InputId) -> Option<&InputState>

Get the state of a specific input.

pub fn remove(&mut self, input_id: &InputId) -> Option<InputState>

Remove an input from the ledger and dedup index.

pub fn get_mut(&mut self, input_id: &InputId) -> Option<&mut InputState>

Get mutable reference to the state of a specific input.

pub fn iter_non_terminal(&self) -> impl Iterator<Item = (&InputId, &InputState)>

Iterate over all non-terminal input states.

pub fn iter(&self) -> impl Iterator<Item = (&InputId, &InputState)>

Iterate over all input states.

pub fn len(&self) -> usize

Number of entries in the ledger.

pub fn is_empty(&self) -> bool

Check if the ledger is empty.

pub fn active_count(&self) -> usize

Number of non-terminal entries.

pub fn active_input_ids(&self) -> Vec<InputId>

Get all active (non-terminal) input IDs.

Trait Implementations

impl Clone for InputLedger

fn clone(&self) -> InputLedger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InputLedger

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

Formats the value using the given formatter.

impl Default for InputLedger

fn default() -> InputLedger

Returns the “default value” for a type.