Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

SQLite store backed by a sqlx connection pool.

All database operations are async and non-blocking. Stores created via SqliteStore::new persist to the given file. Stores created via SqliteStore::new_memory use a transient file that is automatically deleted when the last clone is dropped.

Implementations

impl SqliteStore

pub async fn new(path: &str) -> Result<Self, StoreError>

Create a new SQLite store at the given file path.

The database and schema are created if they do not exist.

Errors

Returns StoreError::Storage if the database cannot be opened or the schema cannot be created.

pub async fn new_memory() -> Result<Self, StoreError>

Create a transient SQLite store backed by a file in the system temp directory. The file and its WAL/SHM companions are removed automatically when the last clone is dropped.

Errors

Returns StoreError::Storage if the schema cannot be created.

Trait Implementations

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl TraceStore for SqliteStore

fn upsert_trace<'life0, 'life1, 'async_trait>( &'life0 self, trace: &'life1 Trace, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Insert or update a trace.

fn insert_observation<'life0, 'life1, 'async_trait>( &'life0 self, observation: &'life1 Observation, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Insert an observation.

fn upsert_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Insert or update a session.

fn get_trace<'life0, 'async_trait>( &'life0 self, id: Id, ) -> Pin<Box<dyn Future<Output = Result<Option<TraceWithObservations>, StoreError>> + Send + 'async_trait>>

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

Get a trace by ID with its observations.

fn query_traces<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 TraceQuery, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResponse<Trace>, StoreError>> + Send + 'async_trait>>

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

Query traces with filtering and pagination.

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, StoreError>> + Send + 'async_trait>>

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

Get a session by ID.

fn query_sessions<'life0, 'async_trait>( &'life0 self, page: u32, page_size: u32, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResponse<Session>, StoreError>> + Send + 'async_trait>>

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

Query sessions with pagination.

fn get_daily_stats<'life0, 'async_trait>( &'life0 self, from: DateTime<Utc>, to: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DailyStats>, StoreError>> + Send + 'async_trait>>

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

Get daily aggregated statistics.

fn get_model_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ModelStats>, StoreError>> + Send + 'async_trait>>

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

Get per-model aggregated statistics.

fn get_summary_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SummaryStats, StoreError>> + Send + 'async_trait>>

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

Get overall summary statistics with latency percentiles.

fn query_enriched_sessions<'life0, 'async_trait>( &'life0 self, page: u32, page_size: u32, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResponse<EnrichedSession>, StoreError>> + Send + 'async_trait>>

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

Query enriched sessions with aggregated data.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Flush any pending writes. Called before process exit.