Struct PostgresStateStore 

pub struct PostgresStateStore { /* private fields */ }

PostgreSQL state store implementation.

Implementations

impl PostgresStateStore

pub async fn new( database_url: impl AsRef<str>, min_connections: Option<u32>, max_connections: Option<u32>, ) -> StateStoreResult<Self>

Create a new PostgreSQL state store with connection pooling.

Arguments

• database_url - PostgreSQL connection string
• min_connections - Minimum number of connections in pool (default: 5)
• max_connections - Maximum number of connections in pool (default: 20)

Example

let store = PostgresStateStore::new(
    "postgresql://user:pass@localhost/workflows",
    Some(5),
    Some(20),
).await?;

pub fn pool(&self) -> &PgPool

Get the connection pool (for advanced use cases).

Trait Implementations

impl StateStore for PostgresStateStore

fn save_workflow_state<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 WorkflowState, ) -> Pin<Box<dyn Future<Output = StateStoreResult<()>> + Send + 'async_trait>>

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

Save or update a workflow state.

fn load_workflow_state<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StateStoreResult<WorkflowState>> + Send + 'async_trait>>

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

Load a workflow state by ID.

fn load_workflow_state_by_workflow_id<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<WorkflowState>> + Send + 'async_trait>>

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

Load a workflow state by workflow ID (gets the most recent).

fn list_active_workflows<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StateStoreResult<Vec<WorkflowState>>> + Send + 'async_trait>>

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

List all active workflows (running or paused).

fn create_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 Checkpoint, ) -> Pin<Box<dyn Future<Output = StateStoreResult<()>> + Send + 'async_trait>>

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

Create a checkpoint.

fn get_latest_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, workflow_state_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StateStoreResult<Option<Checkpoint>>> + Send + 'async_trait>>

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

Get the latest checkpoint for a workflow.

fn restore_from_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = StateStoreResult<WorkflowState>> + Send + 'async_trait>>

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

Restore state from a checkpoint.

fn delete_old_states<'life0, 'async_trait>( &'life0 self, older_than: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = StateStoreResult<u64>> + Send + 'async_trait>>

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

Delete old states (cleanup).

fn cleanup_old_checkpoints<'life0, 'life1, 'async_trait>( &'life0 self, workflow_state_id: &'life1 Uuid, keep_count: usize, ) -> Pin<Box<dyn Future<Output = StateStoreResult<u64>> + Send + 'async_trait>>

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

Delete old checkpoints for a workflow (keep only the last N).

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

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

Health check for the state store.