Crate durable 

Re-exports

pub use ctx::Ctx;

pub use ctx::RetryPolicy;

pub use ctx::TaskQuery;

pub use ctx::TaskSort;

pub use ctx::TaskSummary;

pub use error::DurableError;

pub use executor::Executor;

pub use executor::HeartbeatConfig;

pub use executor::RecoveredTask;

pub use inventory;

Modules

ctx

error

executor

Structs

DatabaseTransaction

Defines a database transaction, whether it is an open transaction and the type of backend to use

WorkflowRegistration

A compiled-in registration of a workflow function for automatic crash recovery.

Enums

TaskStatus

Functions

executor_id

Returns the executor ID set by init, or None if init was not called.

find_workflow

Look up a registered workflow by name.

init

Initialize durable: connect to Postgres, run migrations, start heartbeat, recover stale tasks, and auto-resume registered workflows.

init_db

Initialize durable: connect to Postgres and run migrations only.

init_with_config

Like init but with a custom HeartbeatConfig.

resume_workflow

Resume a failed workflow from its last completed step (DBOS-style).

Attribute Macros

step

Marks a function as a durable step.

workflow

Marks a function as a durable workflow with automatic crash recovery.