Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

PostgreSQL implementation of Backend trait (v0.11.0).

Wraps PostgresStore internally and implements the new Backend interface.

Implementations

impl PostgresBackend

pub fn new(pool: PgPool) -> Self

Create new PostgresBackend from connection pool.

pub fn pool(&self) -> &PgPool

Get reference to underlying pool.

Trait Implementations

impl Backend for PostgresBackend

fn name(&self) -> &'static str

Backend name for diagnostics.

fn publish<'life0, 'async_trait>( &'life0 self, event: DispatchedEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Publish an event to the backend.

fn serve<'life0, 'async_trait, D>( &'life0 self, executor: Arc<JobExecutor<D>>, config: BackendServeConfig, shutdown: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where D: Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Start serving workers (blocking until shutdown).

impl Clone for PostgresBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DeadLetterQueueBackend for PostgresBackend

fn list_dlq<'life0, 'async_trait>( &'life0 self, _filters: DlqFilters, ) -> Pin<Box<dyn Future<Output = Result<Vec<DeadLetter>>> + Send + 'async_trait>>

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

List dead letters with optional filters.

fn retry_dlq<'life0, 'async_trait>( &'life0 self, _event_id: Uuid, _handler_id: String, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Retry a dead letter (re-queue for execution).

impl InsightBackend for PostgresBackend

fn get_workflow_tree<'life0, 'async_trait>( &'life0 self, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<WorkflowTree>> + Send + 'async_trait>>

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

Get workflow execution tree.

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

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

Get aggregate workflow statistics.

impl WorkflowStatusBackend for PostgresBackend

fn get_workflow_status<'life0, 'async_trait>( &'life0 self, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<WorkflowStatus>> + Send + 'async_trait>>

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

Get workflow status for a correlation ID.

impl WorkflowSubscriptionBackend for PostgresBackend

fn subscribe_workflow_events<'life0, 'async_trait>( &'life0 self, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = WorkflowEvent> + Send + Unpin>>> + Send + 'async_trait>>

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

Subscribe to workflow events (LISTEN/NOTIFY pattern).