Struct SqliteReadModelStore 

pub struct SqliteReadModelStore { /* private fields */ }

SQLite implementation of ReadModelStore.

Implementations

impl SqliteReadModelStore

pub async fn new(database_url: &str) -> ReadModelResult<Self>

Build a new store from a database URL. Creates a small r2d2 pool.

pub fn with_pool(pool: Pool<ConnectionManager<SqliteConnection>>) -> Self

Build a store from an existing pool. Used in tests so we can share a single in-memory database with the event store.

Trait Implementations

impl Clone for SqliteReadModelStore

fn clone(&self) -> SqliteReadModelStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ReadModelStore for SqliteReadModelStore

fn upsert<'life0, 'async_trait>( &'life0 self, op: Upsert, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Insert or update a row, version-gated.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Delete a row by primary key. No-op if missing.

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Option<Row>>> + Send + 'async_trait>>

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

Fetch a single row by primary key.

fn find_by<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, table: &'life1 str, field: &'life2 str, value: &'life3 Value, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Vec<Row>>> + Send + 'async_trait>>

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

Fetch all rows where field equals value. Used for secondary-index lookups such as login-by-email. Backends may or may not have an index on the field — the trait carries no guarantee.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Vec<Row>>> + Send + 'async_trait>>

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

Fetch every row in a table.

fn truncate<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Wipe a table. Used during projection rebuild before replay.