Struct DurableInstance 

pub struct DurableInstance { /* private fields */ }

Handle returned by init / init_with_config.

Wraps a database connection, the executor identity, and any tasks recovered from prior crashes. Implements Deref<Target = DatabaseConnection> so it can be passed anywhere a &DatabaseConnection is expected.

let durable = durable::init("postgres://localhost/mydb").await?;

// Use as &DatabaseConnection (via Deref)
let ctx = Ctx::start(&durable, "my_wf", None).await?;

// Or start with executor tracking for proper crash recovery
let ctx = durable.start_workflow("my_wf", None).await?;

// Inspect tasks recovered on startup
for task in durable.recovered() {
    println!("recovered: {} ({})", task.name, task.id);
}

Implementations

impl DurableInstance

pub fn db(&self) -> &DatabaseConnection

The underlying database connection.

pub fn executor_id(&self) -> &str

The unique executor ID for this process.

pub fn recovered(&self) -> &[RecoveredTask]

Tasks recovered from prior crashes during init.

Each entry was reset from RUNNING to PENDING. To resume a recovered workflow, call Ctx::from_id with the task’s id.

pub async fn start_workflow( &self, name: &str, input: Option<Value>, ) -> Result<Ctx, DurableError>

Start a new root workflow, tagging it with this instance’s executor_id so heartbeat-based recovery works if this process crashes.

pub async fn start_workflow_with_timeout( &self, name: &str, input: Option<Value>, timeout_ms: i64, ) -> Result<Ctx, DurableError>

Start a new root workflow with a timeout, tagging it with this instance’s executor_id.

Methods from Deref<Target = DatabaseConnection>

pub async fn ping(&self) -> Result<(), DbErr>

Checks if a connection to the database is still valid.

pub async fn close_by_ref(&self) -> Result<(), DbErr>

Explicitly close the database connection

pub fn get_postgres_connection_pool(&self) -> &Pool<Postgres>

Get sqlx::PgPool

Panics

Panics if DbConn is not a Postgres connection.

Trait Implementations

impl Deref for DurableInstance

type Target = DatabaseConnection

The resulting type after dereferencing.

fn deref(&self) -> &DatabaseConnection

Dereferences the value.