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 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 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.