Struct SqliteProjectionStore 

pub struct SqliteProjectionStore { /* private fields */ }

SQLite-backed projection store

Implementations

impl SqliteProjectionStore

pub fn conn(&self) -> &Arc<Mutex<Connection>>

Get the underlying connection (for migrations and custom queries)

Returns an Arc to the Mutex-protected SQLite connection. Users should lock the mutex to access the connection.

Trait Implementations

impl ProjectionStore for SqliteProjectionStore

type Txn<'a> = SimpleProjectionTxn<'a>

fn open(cfg: ProjectionConfig) -> Result<Self>

Open a projection store

fn close(&self) -> Result<()>

Close the store

fn begin_txn(&self) -> Result<Self::Txn<'_>>

Begin a transaction

fn get_cursor(&self) -> Result<EventId>

Get the current cursor (last applied event ID)

fn migrate(&self, target_version: u32) -> Result<()>

Run migrations to target schema version

fn backup_to(&self, path: &Path) -> Result<()>

Create a backup

fn restore_from(path: &Path, cfg: ProjectionConfig) -> Result<Self>

Restore from a backup

fn schema_version(&self) -> Result<u32>

Get the schema version