Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Cloneable SQLite-backed effect, checkpoint, and journal store.

Clones share one connection and serialize operations at the connection boundary. SQLite transactions still provide persistence and CAS guarantees across separately opened store instances and processes.

Implementations

impl SqliteStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, SqliteStoreError>

Opens or creates a file-backed store and initializes its schema.

Errors

Returns SqliteStoreError when the database cannot be opened or initialized.

pub fn open_in_memory() -> Result<Self, SqliteStoreError>

Creates a process-local SQLite database, primarily for tests.

Errors

Returns SqliteStoreError when SQLite initialization fails.

pub fn events(&self, run_id: RunId) -> Result<Vec<RunEvent>, SqliteStoreError>

Loads all journal events for one Run in sequence order.

Errors

Returns SqliteStoreError when querying or decoding fails.

Trait Implementations

impl CheckpointStore for SqliteStore

fn load(&self, id: CheckpointId) -> Result<Checkpoint, CheckpointError>

Loads the latest checkpoint revision.

fn compare_and_swap( &self, checkpoint: &Checkpoint, expected_revision: Option<u64>, ) -> Result<(), CheckpointError>

Creates or atomically replaces a checkpoint.

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteStore

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EffectStore for SqliteStore

fn load( &self, id: EffectId, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Loads a record by effect identity.

fn find_by_idempotency( &self, capability_id: CapabilityId, key: &str, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Resolves a logical effect by capability-scoped idempotency key.

fn compare_and_swap( &self, record: &EffectRecord, expected_revision: Option<u64>, ) -> Result<(), EffectExecutorError>

Creates or atomically replaces a record.

impl Journal for SqliteStore

fn record(&self, event: &RunEvent) -> Result<(), JournalError>

Records one event.