Module outbox 

Transactional Outbox pattern.

Tail-follows the atomr_persistence_query::ReadJournal and re-emits events into a publish callback, persisting the offset so restarts don’t double-publish. Use this when you have a side-effect (e.g. publishing to Kafka, hitting a webhook) that must occur “at-least-once after every successful aggregate write.”

Structs

InMemoryOffsetStore

In-memory offset store — useful for tests. State is kept in a Mutex<HashMap>; survives restarts of the publisher loop, but not process restarts.

JournalOffsetStore

Durable offset store backed by any Journal backend.

OutboxBuilder

OutboxHandles

OutboxPattern

Public, zero-sized handle to the outbox pattern.

OutboxTopology

Traits

OutboxOffsetStore

Pluggable per-pid offset persistence. load/save return offsets keyed by persistence_id.