Struct MemoryRunStore 

pub struct MemoryRunStore { /* private fields */ }

In-memory RunStore implementation backed by RwLock-protected hash maps.

Stores run records, event streams, and materialised RunState projections in process memory. All data is lost when the store is dropped.

Implementations

impl MemoryRunStore

pub fn new() -> Self

Creates a new in-memory run store.

Trait Implementations

impl Default for MemoryRunStore

fn default() -> Self

Returns the “default value” for a type.

impl RunStore for MemoryRunStore

fn create_run<'life0, 'async_trait>( &'life0 self, record: RunRecord, ) -> Pin<Box<dyn Future<Output = RuntimeResult<()>> + Send + 'async_trait>>

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

Persists a new run record.

fn get_run<'life0, 'async_trait>( &'life0 self, run_id: RunId, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Option<RunRecord>>> + Send + 'async_trait>>

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

Loads a run record by its identifier.

fn get_run_state<'life0, 'async_trait>( &'life0 self, run_id: RunId, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Option<RunState>>> + Send + 'async_trait>>

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

Gets the event-sourced state of a run by replaying its event log.

fn update_run_status<'life0, 'async_trait>( &'life0 self, run_id: RunId, status: RunStatus, ) -> Pin<Box<dyn Future<Output = RuntimeResult<()>> + Send + 'async_trait>>

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

Updates the status of an existing run.

fn append_event<'life0, 'async_trait>( &'life0 self, record: RunEventRecord, ) -> Pin<Box<dyn Future<Output = RuntimeResult<()>> + Send + 'async_trait>>

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

Appends an event to a run’s event log.

fn list_events<'life0, 'async_trait>( &'life0 self, run_id: RunId, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Vec<RunEventRecord>>> + Send + 'async_trait>>

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

Returns the full event log for a run, ordered by sequence number.

fn list_runs<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Vec<RunRecord>>> + Send + 'async_trait>>

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

Lists all runs belonging to a session.

fn list_runs_filtered<'life0, 'async_trait>( &'life0 self, session_id: Option<Uuid>, status: Option<RunStatus>, limit: usize, offset: usize, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Vec<RunRecord>>> + Send + 'async_trait>>

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

Lists runs with optional filters and pagination.

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

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

Deletes a run and all its associated events.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RuntimeResult<()>> + Send + 'async_trait>>

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

Performs a health check against the underlying storage backend.