Struct SqliteEventStoreBackend 

pub struct SqliteEventStoreBackend<E: Event> { /* private fields */ }

Available on crate features cqrs and cqrs-sqlite only.

SQLite-backed event store backend.

Uses WAL journal mode for concurrent read/write access. All operations are executed via spawn_blocking for async compatibility.

Implementations

impl<E: Event> SqliteEventStoreBackend<E>

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

Create a new SQLite event store backend at the given path.

Enables WAL journal mode and creates the events and snapshots tables if they don’t exist.

Trait Implementations

impl<E: Clone + Event> Clone for SqliteEventStoreBackend<E>

fn clone(&self) -> SqliteEventStoreBackend<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Event> EventStoreBackend<E> for SqliteEventStoreBackend<E>

fn append<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, events: Vec<E>, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Append events to an aggregate’s event stream

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get all events for a specific aggregate

fn get_all_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get all events from all aggregates (for projection rebuild)

fn get_events_after<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, version: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get events after a specific version (for snapshot optimization)

fn save_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, snapshot_data: Vec<u8>, version: u64, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Save a snapshot (optional, return Ok(()) if not supported)

fn get_latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(Vec<u8>, u64), String>> + Send + 'async_trait>>

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

Get latest snapshot (optional, return Err if not supported)

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

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

Flush any pending writes (optional, for write-ahead log or batching)

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

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

Get backend statistics