Struct SqlitePersistenceProvider 

pub struct SqlitePersistenceProvider { /* private fields */ }

SQLite-backed persistence provider for the WFE workflow engine.

Implementations

impl SqlitePersistenceProvider

pub async fn new(database_url: &str) -> Result<Self, Box<dyn Error>>

Create a new provider connected to the given SQLite database URL.

For in-memory databases, pass ":memory:". The schema tables are created automatically.

Trait Implementations

impl EventRepository for SqlitePersistenceProvider

fn create_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

fn get_event<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Event>> + Send + 'async_trait>>

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

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

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

fn get_events<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event_name: &'life1 str, event_key: &'life2 str, as_of: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

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

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

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

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

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

impl PersistenceProvider for SqlitePersistenceProvider

fn persist_errors<'life0, 'life1, 'async_trait>( &'life0 self, errors: &'life1 [ExecutionError], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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

impl ScheduledCommandRepository for SqlitePersistenceProvider

fn supports_scheduled_commands(&self) -> bool

fn schedule_command<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 ScheduledCommand, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn process_commands<'life0, 'life1, 'async_trait>( &'life0 self, as_of: DateTime<Utc>, handler: &'life1 (dyn Fn(ScheduledCommand) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync), ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

impl SubscriptionRepository for SqlitePersistenceProvider

fn create_event_subscription<'life0, 'life1, 'async_trait>( &'life0 self, subscription: &'life1 EventSubscription, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

fn get_subscriptions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event_name: &'life1 str, event_key: &'life2 str, as_of: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventSubscription>>> + Send + 'async_trait>>

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

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

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

fn get_subscription<'life0, 'life1, 'async_trait>( &'life0 self, subscription_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<EventSubscription>> + Send + 'async_trait>>

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

fn get_first_open_subscription<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event_name: &'life1 str, event_key: &'life2 str, as_of: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Option<EventSubscription>>> + Send + 'async_trait>>

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

fn set_subscription_token<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, subscription_id: &'life1 str, token: &'life2 str, worker_id: &'life3 str, expiry: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

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

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

impl WorkflowRepository for SqlitePersistenceProvider

fn create_new_workflow<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 WorkflowInstance, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

fn persist_workflow<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 WorkflowInstance, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn persist_workflow_with_subscriptions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance: &'life1 WorkflowInstance, subscriptions: &'life2 [EventSubscription], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

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

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

fn get_workflow_instance<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowInstance>> + Send + 'async_trait>>

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

fn get_workflow_instance_by_name<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowInstance>> + Send + 'async_trait>>

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

fn next_definition_sequence<'life0, 'life1, 'async_trait>( &'life0 self, definition_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Atomically allocate the next sequence number for a given workflow definition id. Used by the host to assign human-friendly names of the form {definition_id}-{N} before inserting a new workflow instance. Guaranteed monotonic per definition_id; no guarantees across definitions.

fn get_workflow_instances<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowInstance>>> + Send + 'async_trait>>

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