nestrs-outbox API - Nestrs

Crate: nestrs-outbox · Feature: outbox · Guide: Outbox

nestrs-outbox = "1.7.1"

`OutboxModule::register`

Exports OutboxRelay and OutboxOptions.

`OutboxRelay`

pub fn from_options(opts: &OutboxOptions) -> Self
pub fn store(&self) -> SharedOutboxStore
pub async fn add(&self, topic: &str, payload: Value) -> OutboxMessage
pub async fn tick(&self, publish: &PublishFn)

PublishFn = Arc<dyn Fn(String, Value) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send>> + Send + Sync>.

`OutboxOptions`

Field	Default
`store`	`InMemoryOutboxStore`
`max_attempts`	10
`poll_interval`	1s
`batch_size`	32
`allow_in_memory`	true

Statuses

OutboxStatus: pending → published | retry → dead letter after max attempts.