Struct SqliteReplayStore 

pub struct SqliteReplayStore { /* private fields */ }

SQLite-backed persistent ReplayStore.

Open with SqliteReplayStore::open (file path) or SqliteReplayStore::open_in_memory (tests). Both return the store plus an AsyncIsleDriver the caller must shutdown().await when done — dropping the driver without a shutdown call leaves the SQLite thread as-is until the process exits.

Implementations

impl SqliteReplayStore

pub async fn open( path: impl AsRef<Path>, ) -> Result<(Self, AsyncIsleDriver), ReplayStoreError>

Open (or create) a SQLite database file and run the schema migrations. See [init_schema] and the module-level Schema versioning doc.

pub async fn open_in_memory() -> Result<(Self, AsyncIsleDriver), ReplayStoreError>

Open an ephemeral in-memory database (tests, doctests). In-memory databases start with user_version = 0 and are always fresh, so [init_schema] takes the version-0 arm and stamps CURRENT_SCHEMA_VERSION immediately.

Trait Implementations

impl ReplayStore for SqliteReplayStore

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