Crate fleetforge_bus 

Kafka-compatible event bus utilities and transactional outbox forwarder.

Structs

BusConfig

Configuration for the event bus forwarder.

OutboxForwarder

Forwarder that drains the transactional outbox and publishes records.

Traits

OutboxExporter

External sink that receives a copy of every outbox event.

Functions

run_outbox_forwarder

Spawns an outbox forwarder task.

run_outbox_forwarder_with_exporters

Spawns an outbox forwarder task with additional exporters that fan out a copy of each event.