Struct InMemoryReplayStore 

pub struct InMemoryReplayStore { /* private fields */ }

Process-volatile ReplayStore — the default backend. Entries are lost on restart; use SqliteReplayStore when survive-restart is what the caller wants.

Implementations

impl InMemoryReplayStore

pub fn new() -> Self

Create an empty store.

Trait Implementations

impl Default for InMemoryReplayStore

fn default() -> InMemoryReplayStore

Returns the “default value” for a type.

impl ReplayStore for InMemoryReplayStore

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn append<'life0, 'async_trait>( &'life0 self, entry: ReplayEntry, ) -> Pin<Box<dyn Future<Output = Result<(), ReplayStoreError>> + Send + 'async_trait>>

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

Append one entry. Returns ReplayStoreError::Duplicate if the backend already carries a row with the same (run_id, step_ref, input_hash, occurrence).

fn list_by_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, ) -> Pin<Box<dyn Future<Output = Result<Vec<ReplayEntry>, ReplayStoreError>> + Send + 'async_trait>>

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

Return every entry for run_id, in insertion order (the order the dispatcher wrote them).

fn delete_from<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, from_index: usize, ) -> Pin<Box<dyn Future<Output = Result<usize, ReplayStoreError>> + Send + 'async_trait>>

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

Delete every entry for run_id whose position in insertion order is >= from_index — i.e. keep the first from_index entries and drop the rest. Returns the number of rows deleted.