Struct SqliteOutboxWorkerBuilder 

pub struct SqliteOutboxWorkerBuilder { /* private fields */ }

Fluent builder for an OutboxWorker backed by SqliteOutboxStore.

See the module documentation for the single-worker concurrency model.

Implementations

impl SqliteOutboxWorkerBuilder

pub fn new(pool: SqlitePool) -> Self

Start a new builder for the given pool.

pub fn table_name(self, name: impl Into<String>) -> Self

Override the outbox table name (default "audit_outbox").

pub fn register_handler<E, H>(self, handler: H) -> Self

where E: Event, H: Handler<E>,

Register a typed handler for the event type E.

Registering twice for the same event type silently replaces the previous handler.

pub fn shared_handler<E, H>(self, handler: Arc<H>) -> Self

where E: Event, H: Handler<E>,

Register a handler already shared behind an Arc.

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

Override the poll interval (default 100 ms).

pub fn batch_size(self, n: usize) -> Self

Override the batch size per poll (default 10).

pub fn max_attempts(self, n: u32) -> Self

Override the maximum number of attempts per envelope (default 5).

pub fn retry_delay(self, d: Duration) -> Self

Override the constant retry delay between failed attempts (default 5 s).

pub fn build(self) -> Result<OutboxWorker<SqliteOutboxStore>, OutboxError>

Consume the builder and produce an OutboxWorker ready to spawn.

Errors

Returns OutboxError::Internal if the configured table_name is not a valid identifier.