Struct SqliteRunTraceStore 

pub struct SqliteRunTraceStore { /* private fields */ }

SQLite-backed persistent RunTraceStore.

Open with SqliteRunTraceStore::open (file path — typically the SAME path as the SqliteRunStore) or SqliteRunTraceStore::open_in_memory (tests). Both return the store plus an AsyncIsleDriver the caller must shutdown().await when done.

Implementations

impl SqliteRunTraceStore

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

Open (or create) a SQLite database file and ensure the run_trace table exists. Safe to point at the file another store already owns — CREATE TABLE IF NOT EXISTS never touches foreign tables.

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

Open an ephemeral in-memory database (tests, doctests).

pub fn with_max_events_per_run(self, max: usize) -> Self

Override the per-Run retention ceiling (tests).

Trait Implementations

impl RunTraceStore for SqliteRunTraceStore

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn append<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, draft: TraceEventDraft, ) -> Pin<Box<dyn Future<Output = Result<TraceEvent, TraceStoreError>> + Send + 'async_trait>>

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

Append one event to run_id’s stream, assigning the next seq and stamping ts_ms. The store caps draft.payload via cap_payload and prunes the oldest rows beyond the per-Run retention ceiling. Appending to an unknown run_id is legal — the trace rail has no foreign-key coupling to RunStore (a trace writer must never fail because Run-row creation raced it).

fn list<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_id: &'life1 RunId, query: &'life2 TraceQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<TraceEvent>, TraceStoreError>> + Send + 'async_trait>>

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

List run_id’s events matching query, ascending by seq.

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

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

Delete every event belonging to run_id, returning the number of deleted events. Deleting an unknown/empty Run is Ok(0).