Struct InMemorySessionLedger 

pub struct InMemorySessionLedger { /* private fields */ }

The in-process ledger.

Implementations

impl InMemorySessionLedger

pub fn new(session_id: SessionId, config: IngestionConfig) -> Self

A ledger for one session.

pub fn session_id(&self) -> &SessionId

The session this ledger belongs to.

pub fn revision(&self) -> u64

The ledger revision, bumped on every accepted observation.

pub fn len(&self) -> usize

How many candidates are held.

pub fn is_empty(&self) -> bool

Whether the ledger holds no candidates.

pub fn usable_candidates(&self) -> Vec<SessionCandidate>

Candidates usable for retrieval right now.

pub fn micro_reconcile(&self) -> MicroReconciliationReport

Merge duplicates, resolve in-session contradictions, and re-evaluate statuses (§18).

Runs on a cadence during the session. Deliberately local: it compares candidates against each other, never against the durable corpus.

Trait Implementations

impl Debug for InMemorySessionLedger

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

Formats the value using the given formatter.

impl SessionLedger for InMemorySessionLedger

fn append_observation<'life0, 'async_trait>( &'life0 self, observation: MemoryObservation, ) -> Pin<Box<dyn Future<Output = Result<LedgerOutcome, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Offer an observation to the ledger.

fn snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SessionLedgerSnapshot, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read the current candidate set.

fn seal<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SealedSessionLedger, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the ledger and hand its candidates to consolidation.