Struct SqliteFlowStore 

pub struct SqliteFlowStore { /* private fields */ }

Implementations

impl SqliteFlowStore

pub async fn open(path: &str) -> Result<Self, FlowError>

Open or create a SQLite database at path. Use :memory: for tests.

pub async fn with_pool(pool: SqlitePool) -> Result<Self, FlowError>

Open against a pool the caller already owns. Useful for tests that share an in-memory DB across multiple stores.

pub fn pool(&self) -> &SqlitePool

Trait Implementations

impl Clone for SqliteFlowStore

fn clone(&self) -> SqliteFlowStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FlowStore for SqliteFlowStore

fn update_and_append<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, flow: &'life1 Flow, event_kind: &'life2 str, event_payload: Value, ) -> Pin<Box<dyn Future<Output = Result<(Flow, FlowEvent), FlowError>> + Send + 'async_trait>>

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

Atomic override: runs the revision check, UPDATE, event INSERT, and final SELECT inside one SQLite transaction. A crash at any point rolls back and the caller sees either the full old state or the full new state + event — no torn audit trail.

fn insert<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 Flow, ) -> Pin<Box<dyn Future<Output = Result<(), FlowError>> + Send + 'async_trait>>

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

fn get<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Flow>, FlowError>> + Send + 'async_trait>>

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

fn list_by_owner<'life0, 'life1, 'async_trait>( &'life0 self, owner_session_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Flow>, FlowError>> + Send + 'async_trait>>

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

fn list_by_status<'life0, 'async_trait>( &'life0 self, status: FlowStatus, ) -> Pin<Box<dyn Future<Output = Result<Vec<Flow>, FlowError>> + Send + 'async_trait>>

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

fn update_with_revision<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 Flow, ) -> Pin<Box<dyn Future<Output = Result<Flow, FlowError>> + Send + 'async_trait>>

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

fn append_event<'life0, 'life1, 'async_trait>( &'life0 self, flow_id: Uuid, kind: &'life1 str, payload: Value, ) -> Pin<Box<dyn Future<Output = Result<FlowEvent, FlowError>> + Send + 'async_trait>>

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

fn list_events<'life0, 'async_trait>( &'life0 self, flow_id: Uuid, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<FlowEvent>, FlowError>> + Send + 'async_trait>>

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

fn insert_step<'life0, 'life1, 'async_trait>( &'life0 self, step: &'life1 FlowStep, ) -> Pin<Box<dyn Future<Output = Result<(), FlowError>> + Send + 'async_trait>>

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

fn update_step<'life0, 'life1, 'async_trait>( &'life0 self, step: &'life1 FlowStep, ) -> Pin<Box<dyn Future<Output = Result<FlowStep, FlowError>> + Send + 'async_trait>>

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

fn get_step<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<FlowStep>, FlowError>> + Send + 'async_trait>>

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

fn list_steps<'life0, 'async_trait>( &'life0 self, flow_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<FlowStep>, FlowError>> + Send + 'async_trait>>

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

fn find_step_by_run_id<'life0, 'life1, 'async_trait>( &'life0 self, flow_id: Uuid, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<FlowStep>, FlowError>> + Send + 'async_trait>>

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

fn prune_terminal_flows<'life0, 'async_trait>( &'life0 self, retain_days: i64, ) -> Pin<Box<dyn Future<Output = Result<u64, FlowError>> + Send + 'async_trait>>

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

Drop flows in terminal status (Finished, Failed, Cancelled) whose updated_at is older than retain_days. Cascades through flow_steps and flow_events via ON DELETE CASCADE in schema. Intended for a daily heartbeat so list_by_owner / list_by_ status don’t grow O(n) over all history. Default impl returns an error — stores must override.