Struct OutboxDrainer 

pub struct OutboxDrainer<H> { /* private fields */ }

Polling drainer delivering entity_outbox rows to a handler.

Implementations

impl<H: OutboxHandler> OutboxDrainer<H>

pub fn new(pool: PgPool, handler: H) -> Self

Create a drainer with defaults: batch 32, poll every second, backoff base 5s, 10 attempts.

pub fn batch_size(self, batch_size: i64) -> Self

Set the maximum rows claimed per polling cycle.

pub fn poll_interval(self, poll_interval: Duration) -> Self

Set the sleep between empty polling cycles.

pub fn base_backoff(self, base_backoff: Duration) -> Self

Set the exponential-backoff base delay.

pub fn max_attempts(self, max_attempts: i32) -> Self

Set the retry ceiling before a row is parked.

pub async fn run(self)

Drain continuously until the surrounding task is cancelled.

pub async fn drain_once(&self) -> Result<usize, Error>

Claim and deliver one batch.

Returns the number of rows processed (successfully or scheduled for retry).

Errors

Propagates database errors from claiming or updating rows.