Struct InMemoryRunTraceStore 

pub struct InMemoryRunTraceStore { /* private fields */ }

Process-volatile RunTraceStore — the default when no persistent backend is wired.

Implementations

impl InMemoryRunTraceStore

pub fn new() -> Self

Create an empty store with the default retention ceiling.

pub fn with_max_events_per_run(max: usize) -> Self

Create an empty store with a custom per-Run retention ceiling (tests).

Trait Implementations

impl Default for InMemoryRunTraceStore

fn default() -> Self

Returns the “default value” for a type.

impl RunTraceStore for InMemoryRunTraceStore

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn append<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, draft: TraceEventDraft, ) -> Pin<Box<dyn Future<Output = Result<TraceEvent, TraceStoreError>> + Send + 'async_trait>>

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

Append one event to run_id’s stream, assigning the next seq and stamping ts_ms. The store caps draft.payload via cap_payload and prunes the oldest rows beyond the per-Run retention ceiling. Appending to an unknown run_id is legal — the trace rail has no foreign-key coupling to RunStore (a trace writer must never fail because Run-row creation raced it).

fn list<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 RunId, query: &'life2 TraceQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<TraceEvent>, TraceStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List run_id’s events matching query, ascending by seq.

fn delete_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, ) -> Pin<Box<dyn Future<Output = Result<u64, TraceStoreError>> + Send + 'async_trait>>

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

Delete every event belonging to run_id, returning the number of deleted events. Deleting an unknown/empty Run is Ok(0).