Struct LibSqlStore 

pub struct LibSqlStore { /* private fields */ }

Durable EventStore backed by a shared libSQL connection.

Implementations

impl LibSqlStore

pub async fn connect(config: LibSqlConfig) -> Result<Self, StoreError>

Open a store from operator-provided libSQL configuration.

Errors

Returns StoreError::Backend when the connection cannot be opened or when the idempotent schema DDL cannot be applied.

pub async fn open(path: impl Into<PathBuf>) -> Result<Self, StoreError>

Open an embedded local-file store at path.

Operator tunables remain unset; this convenience constructor only selects embedded mode.

Errors

Returns StoreError::Backend when the connection cannot be opened or when the idempotent schema DDL cannot be applied.

pub async fn validate_event_compatibility(&self) -> Result<(), StoreError>

Validate stored event blobs against the current Aion event schema.

Errors

Returns StoreError::Serialization when any stored event cannot be decoded by the current event schema, or StoreError::Backend for libSQL scan failures.

pub async fn sync(&self) -> Result<(), StoreError>

Trigger and await a libSQL replica synchronization cycle.

Errors

Returns StoreError::Backend when the current libSQL database mode does not support sync or when the replica sync operation fails.

Trait Implementations

impl Clone for LibSqlStore

fn clone(&self) -> LibSqlStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ReadableEventStore for LibSqlStore

fn read_history<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 WorkflowId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, StoreError>> + Send + 'async_trait>>

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

Reads the complete event history for workflow_id in ascending sequence order.

fn read_history_from<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 WorkflowId, from_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, StoreError>> + Send + 'async_trait>>

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

Reads the event history for workflow_id restricted to events with sequence number greater than or equal to from_seq, in ascending sequence order.

fn read_run_chain<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 WorkflowId, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunSummary>, StoreError>> + Send + 'async_trait>>

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

Reads the concrete run chain for workflow_id in continuation order.

fn list_workflow_ids<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowId>, StoreError>> + Send + 'async_trait>>

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

Lists every workflow identifier that has at least one event in history.

fn list_active<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowId>, StoreError>> + Send + 'async_trait>>

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

Lists workflow identifiers whose projected status is non-terminal.

fn query<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 WorkflowFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowSummary>, StoreError>> + Send + 'async_trait>>

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

Returns workflow summaries matching filter.

fn schedule_timer<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, workflow_id: &'life1 WorkflowId, timer_id: &'life2 TimerId, fire_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Persists a durable timer for workflow_id that is due at fire_at.

fn expired_timers<'life0, 'async_trait>( &'life0 self, as_of: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<TimerEntry>, StoreError>> + Send + 'async_trait>>

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

Returns durable timers whose fire_at is less than or equal to as_of.

impl VisibilityStore for LibSqlStore

fn record_visibility<'life0, 'async_trait>( &'life0 self, record: VisibilityRecord, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Upserts a workflow visibility record.

fn list_workflows<'life0, 'async_trait>( &'life0 self, filter: ListWorkflowsFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<VisibilityWorkflowSummary>, StoreError>> + Send + 'async_trait>>

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

Lists workflow visibility summaries matching filter.

fn count_workflows<'life0, 'async_trait>( &'life0 self, filter: ListWorkflowsFilter, ) -> Pin<Box<dyn Future<Output = Result<u64, StoreError>> + Send + 'async_trait>>

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

Counts workflow visibility summaries matching filter.

impl WritableEventStore for LibSqlStore

fn append<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _token: WriteToken, workflow_id: &'life1 WorkflowId, events: &'life2 [Event], expected_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Atomically appends events to workflow_id when the stored history head equals expected_seq.