Skip to main content

dispatch_completion

Function dispatch_completion 

Source
pub async fn dispatch_completion(
    pool: &PgPool,
    event_id: i64,
) -> Result<DispatchOutcome, EngineError>
Expand description

Public entry point — poll one outbox event and cascade.

The caller owns polling cadence + ordering. Typical usage is a tokio task that subscribes to [super::completion::subscribe] and invokes this function for each payload’s event_id.