Module bus 

Live event distribution behind a trait.

Standalone uses InProcessBus (a tokio broadcast channel); the clustered crate::DistributedBus (Postgres LISTEN/NOTIFY) drops in behind the same trait — see the topology design spec §3.2. Both expose the live tail as a per-stream BusSubscription; consumers dedup the history/live overlap on seq.

Structs

InProcessBus

In-process broadcast bus — the standalone implementation.

Enums

BusEvent

One item from a per-stream live subscription (transport-agnostic).

Traits

EventBus

Publishes events to live subscribers.

Type Aliases

BusSubscription

A live, per-stream subscription: an ordered stream of BusEvents for one stream key. Ends (None) when the bus is gone.