Struct MemoryLedger 

pub struct MemoryLedger { /* private fields */ }

In-memory SessionLedger for tests and for callers that hold the live SessionRef map next to the bridge.

Implementations

impl MemoryLedger

pub fn new() -> Self

pub fn track_task(&self, task_id: &str, attempt: i64)

Register a task the bridge may seed a row for, with its attempt count.

pub fn track_session(&self, session: SessionRef)

Insert a live session ref the bridge prefers over the stored reference.

pub fn events(&self) -> Vec<(String, Value)>

pub fn alerts(&self) -> Vec<String>

Trait Implementations

impl Debug for MemoryLedger

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

Formats the value using the given formatter.

impl Default for MemoryLedger

fn default() -> Self

Returns the “default value” for a type.

impl SessionLedger for MemoryLedger

fn get_session(&self, task_id: &str) -> Result<Option<SessionRecord>>

Load the session row serving one delivery.

fn upsert_session( &self, task_id: &str, version: &VersionedSession, ) -> Result<bool>

Monotonic session upsert, which also opens the delivery’s binding. Returns true when the row changed.

fn task_is_known(&self, task_id: &str) -> Result<bool>

Whether the task itself is tracked, so a stray report cannot conjure a row.

fn task_attempt(&self, task_id: &str) -> Result<i64>

Attempt count for a task, for the fault audit entry.

fn list_faults(&self, task_id: &str) -> Result<Vec<FaultRecord>>

Existing faults for one task, for the (task_id, kind, generation) dedupe.

fn insert_fault(&self, fault: &FaultRecord) -> Result<i64>

Append one fault row. Returns its id.

fn emit(&self, kind: &str, data: Value)

Observe an emitted event. The bridge never reads back from this hook.

fn note_alert(&self, line: String)

Observe an operator-visible alert line.