Struct MemoryRuntimeEventStore 

pub struct MemoryRuntimeEventStore { /* private fields */ }

In-memory RuntimeEventStore for tests and single-instance development.

seq is monotonic per run_id. When a AgentEvent::RunStarted is appended, its session_id is cached and attached to subsequent events of the same run. All state is guarded by a single Mutex so sequence assignment, session propagation, and event insertion are atomic per RuntimeEventStore::append.

Implementations

impl MemoryRuntimeEventStore

pub fn new() -> Self

Creates an empty store.

Trait Implementations

impl Debug for MemoryRuntimeEventStore

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

Formats the value using the given formatter.

impl Default for MemoryRuntimeEventStore

fn default() -> MemoryRuntimeEventStore

Returns the “default value” for a type.

impl RuntimeEventStore for MemoryRuntimeEventStore

fn append<'life0, 'async_trait>( &'life0 self, event: AgentEvent, ) -> Pin<Box<dyn Future<Output = Result<RuntimeEventEnvelope, RuntimeEventStoreError>> + Send + 'async_trait>>

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

Appends an event and returns the resulting envelope with identity and sequence assigned.

fn list_after<'life0, 'async_trait>( &'life0 self, run_id: RunId, after_seq: Option<u64>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<RuntimeEventEnvelope>, RuntimeEventStoreError>> + Send + 'async_trait>>

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

Replays events for run_id with seq > after_seq.