Struct SqlWorkflowEngine 

pub struct SqlWorkflowEngine { /* private fields */ }

PostgreSQL-backed workflow runtime engine.

Provides durable implementations of sleep(), await_deferred(), and resolve_deferred() that persist to the database and survive restarts.

Example

use sqlx::postgres::PgPool;
use cruster::storage::sql_workflow_runtime::SqlWorkflowEngine;

let pool = PgPool::connect("postgres://...").await?;
cruster::storage::migrate(&pool).await?;
let engine = SqlWorkflowEngine::new(pool);

Implementations

impl SqlWorkflowEngine

pub fn new(pool: PgPool) -> Self

Create a new SQL workflow runtime engine with the given connection pool.

Run crate::storage::migrate before using SQL storage backends.

pub fn with_poll_interval(pool: PgPool, poll_interval: Duration) -> Self

Create a new SQL workflow runtime engine with a custom poll interval.

The poll interval controls how often the engine checks the database for timer/deferred state changes. Lower values provide faster response but increase database load.

pub async fn cleanup(&self, older_than: Duration) -> Result<u64, ClusterError>

Clean up old completed entries from the database.

Deletes timers that have fired and deferred values that have been resolved older than the specified duration.