Duroxide PostgreSQL Provider

A PostgreSQL-based provider implementation for Duroxide, a durable task orchestration framework for Rust.

Note: See CHANGELOG.md for version history and breaking changes.

Installation

Add to your Cargo.toml:

[dependencies]
duroxide-pg = "0.1"

Usage

use duroxide_pg::PostgresProvider;
use duroxide::Worker;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Create a provider with the database URL
    let provider = PostgresProvider::new("postgres://user:password@localhost:5432/mydb").await?;

    // Use with a Duroxide worker
    let worker = Worker::new(provider);
    // ... register orchestrations and activities, then run
    
    Ok(())
}

Custom Schema

To isolate data in a specific PostgreSQL schema:

let provider = PostgresProvider::new_with_schema(
    "postgres://user:password@localhost:5432/mydb",
    Some("my_schema"),
).await?;

Configuration

Features

• Automatic schema migration on startup
• Connection pooling via sqlx
• Custom schema support for multi-tenant isolation
• Full implementation of the Duroxide Provider and ProviderAdmin traits
• Poison message detection with attempt count tracking
• Lock renewal for long-running orchestrations and activities
• KV store — durable per-instance key-value state for orchestration coordination
• Orchestration stats introspection via Client::get_orchestration_stats()

Latest Release (0.1.28)

• Updated to duroxide 0.1.27 with provider-side get_instance_stats() support
• Fixed deserialization error propagation: read(), read_with_execution(), and read_history_with_execution_id() now surface malformed events as ProviderError::permanent
• Fixed get_instance_stats carry_forward JSONB path and removed error-swallowing EXCEPTION block
• Added 8 new validation tests (2 corrupted history + 6 stats)
• Added sample_orchestration_stats and sample_kv_read_modify_write_counter e2e coverage
• See CHANGELOG.md for full version history

License

MIT License - see LICENSE for details.