Struct SqliteBackend 

pub struct SqliteBackend { /* private fields */ }

SQLite persistence backend.

Clone is cheap — it only clones the mpsc::SyncSender handle.

The writer thread shuts down automatically when all SyncSender handles (i.e. all SqliteBackend clones) are dropped.

Implementations

impl SqliteBackend

pub fn new<P: AsRef<Path>>(path: P) -> Result<Self, PersistenceError>

Opens (or creates) a SQLite database at path and starts the writer thread.

Schema and WAL mode are configured synchronously here — no block_on needed, no async runtime required at construction time.

Trait Implementations

impl Clone for SqliteBackend

fn clone(&self) -> SqliteBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PersistenceBackend for SqliteBackend

fn store<'a>( &'a self, record_name: &'a str, value: &'a Value, timestamp: u64, ) -> BoxFuture<'a, Result<(), PersistenceError>>

Store a JSON value for a record.

fn query<'a>( &'a self, record_pattern: &'a str, params: QueryParams, ) -> BoxFuture<'a, Result<Vec<StoredValue>, PersistenceError>>

Query stored values, with optional pattern and time-range support.

fn cleanup( &self, older_than: u64, ) -> BoxFuture<'_, Result<u64, PersistenceError>>

Delete all rows older than older_than (Unix ms).

fn initialize( &self, ) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + '_>>

Initialize storage (create tables, indexes, …).