Struct SqliteEventStore 

pub struct SqliteEventStore { /* private fields */ }

A3S ORM-backed SQLite event store for single-node durable hosts.

The store keeps one row per FlowEventEnvelope and uses an ORM-managed immediate transaction for expected-sequence append safety and audit-safe whole-history retention.

Implementations

impl SqliteEventStore

pub async fn hold_history( &self, run_id: &str, hold_id: &str, reason: &str, ) -> Result<()>

Persist an audit hold that prevents a run history from being pruned.

Repeating the same (run_id, hold_id, reason) is idempotent. Reusing a hold ID with another reason returns a conflict so audit intent cannot be silently replaced.

pub async fn release_history_hold( &self, run_id: &str, hold_id: &str, ) -> Result<bool>

Release one audit hold. Returns false when the hold did not exist.

pub async fn history_holds(&self, run_id: &str) -> Result<Vec<FlowHistoryHold>>

List durable audit holds for one run in stable hold-ID order.

pub async fn history_tombstone( &self, run_id: &str, ) -> Result<Option<FlowHistoryTombstone>>

Read the minimal audit tombstone retained after history deletion.

pub async fn prune_terminal_history( &self, policy: FlowHistoryRetentionPolicy, ) -> Result<FlowHistoryRetentionReport>

Delete complete eligible terminal histories in one immediate transaction.

The scan preserves durable holds and linked components, writes a checksum tombstone, and only then deletes event rows. It never performs partial stream compaction.

impl SqliteEventStore

pub async fn connect(database_url: impl AsRef<str>) -> Result<Self>

Open a SQLite database and run Flow migrations.

The common sqlite::memory:, sqlite://:memory:, and :memory: forms create an in-memory database. Other values may be paths or use a sqlite: or sqlite:// prefix.

pub async fn from_executor(executor: SqliteExecutor) -> Result<Self>

Create a store from a configured executor and run Flow migrations.

pub fn executor(&self) -> &SqliteExecutor

Return the executor used by this store.

Trait Implementations

impl Clone for SqliteEventStore

fn clone(&self) -> SqliteEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteEventStore

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

Formats the value using the given formatter.

impl FlowEventStore for SqliteEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

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

Append event to run_id and return its durable envelope.

fn append_if_sequence<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, expected_sequence: u64, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

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

Append event only when the run’s latest sequence equals expected_sequence.

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

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

Load the complete event history for run_id in sequence order.

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

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

List all run IDs known to the store in stable order.

fn list_due_wakeups<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduledWakeup>>> + Send + 'async_trait>>

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

List wait timers and delayed retries due at or before now.

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

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

Return the earliest wait timer or delayed retry across active runs.

fn find_active_hooks_by_token<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ActiveHookSnapshot>>> + Send + 'async_trait>>

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

Find active hooks that own an external callback token.

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

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

List active external callback hooks in stable run/hook order.