Struct InMemoryRunLogStore 

pub struct InMemoryRunLogStore { /* private fields */ }

In-process, in-memory RunLogStore. The default when no backend is wired.

Implementations

impl InMemoryRunLogStore

pub fn new() -> Self

Construct an empty store.

Trait Implementations

impl Default for InMemoryRunLogStore

fn default() -> InMemoryRunLogStore

Returns the “default value” for a type.

impl RunLogStore for InMemoryRunLogStore

fn put<'life0, 'life1, 'async_trait>( &'life0 self, run_log: &'life1 RunLog, ) -> Pin<Box<dyn Future<Output = Result<(), RunLogError>> + Send + 'async_trait>>

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

Persist (insert or replace) a RunLog keyed by its run_id.

fn get<'life0, 'async_trait>( &'life0 self, run_id: RunId, ) -> Pin<Box<dyn Future<Output = Result<Option<RunLog>, RunLogError>> + Send + 'async_trait>>

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

Fetch a RunLog by run_id. Ok(None) when not present.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 RunLogQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunLog>, RunLogError>> + Send + 'async_trait>>

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

List runs most-recent-first, filtered and paginated per RunLogQuery. All filters (agent, status) are applied before limit/offset so the returned page reflects the full filtered set, not a post-filtered slice.

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

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

Remove a run.