Struct InMemoryRunStore 

pub struct InMemoryRunStore { /* private fields */ }

Implementations

impl InMemoryRunStore

pub fn new() -> Self

pub fn with_retention( max_runs: Option<usize>, max_events_per_run: Option<usize>, ) -> Self

Construct a store with optional FIFO retention caps. None fields keep the unbounded default.

pub fn with_retention_limits( max_runs: Option<usize>, max_events_per_run: Option<usize>, max_event_bytes_per_run: Option<usize>, ) -> Self

Construct a store with count and serialized-byte FIFO retention caps.

pub async fn create_run(&self, session_id: &str, prompt: &str) -> RunSnapshot

pub async fn create_run_with_id( &self, id: String, session_id: &str, prompt: &str, ) -> RunSnapshot

Create a run with a caller-supplied id. Used by the session orchestration layer so the parent session’s host-provided IdGenerator governs run ids.

pub async fn record_event( &self, run_id: &str, event: AgentEvent, ) -> Option<RunSnapshot>

pub async fn mark_failed( &self, run_id: &str, error: impl Into<String>, ) -> Option<RunSnapshot>

pub async fn mark_cancelled(&self, run_id: &str) -> Option<RunSnapshot>

pub async fn snapshot(&self, run_id: &str) -> Option<RunSnapshot>

pub async fn events(&self, run_id: &str) -> Vec<RunEventRecord>

pub async fn event_page( &self, run_id: &str, after_sequence: Option<usize>, limit: usize, ) -> Option<RunEventPage>

Return retained events strictly after after_sequence, bounded by limit. The page reports when the requested cursor predates the retained FIFO window. None distinguishes an unknown run from a known run whose event window is empty.

pub async fn list(&self) -> Vec<RunSnapshot>

pub async fn records(&self) -> Vec<RunRecord>

pub async fn replace_records(&self, records: Vec<RunRecord>)

Trait Implementations

impl Debug for InMemoryRunStore

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

Formats the value using the given formatter.

impl Default for InMemoryRunStore

fn default() -> InMemoryRunStore

Returns the “default value” for a type.