Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

A SQLite-backed implementation of LedgerStore.

Uses connection pooling via sqlx::SqlitePool for efficient concurrent access.

Implementations

impl SqliteStore

pub async fn new(db_url: &str) -> Result<Self, ZakatError>

Creates a new SQLite store and ensures the schema is initialized.

Arguments

• db_url - SQLite connection URL (e.g., "sqlite::memory:" or "sqlite:ledger.db?mode=rwc")

Errors

Returns ZakatError::NetworkError if connection or migration fails.

pub fn from_pool(pool: SqlitePool) -> Self

Creates a new SqliteStore from an existing pool.

Note: This does NOT run migrations. Use new() for automatic schema setup.

pub fn pool(&self) -> &SqlitePool

Returns a reference to the underlying connection pool.

Trait Implementations

impl LedgerStore for SqliteStore

fn save_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 LedgerEvent, ) -> Pin<Box<dyn Future<Output = Result<(), ZakatError>> + Send + 'async_trait>>

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

Saves a single event to the store.

fn load_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<LedgerEvent>, ZakatError>> + Send + 'async_trait>>

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

Loads all events from the store.