Struct EventBus 

pub struct EventBus { /* private fields */ }

Registry of handlers, built once by Harness::build from every module’s events(). Cheap to clone (two Arcs).

Implementations

impl EventBus

pub fn new() -> Self

An empty bus (a harness with no subscriptions).

pub fn on(self, name: impl Into<EventName>, handler: EventHandler) -> Self

Builds a bus from collected (name, handler) pairs, appending the new pairs after any existing ones (copy-on-write if the bus is already shared). Modules register via Module::events() at Harness::build.

pub fn handlers(&self) -> &[(EventName, EventHandler)]

The registered (name, handler) pairs, in registration order.

pub fn deliver_inbound( &self, scope: &Scope, name: &str, payload: &Value, ) -> usize

The sidecar half of event forwarding (issue #62): the delivery the host posted to POST /__events, run against this deployment’s own handlers and this request’s defer. Returns the number of handlers that subscribed, so the route can refuse to be silent about an event nobody hears.

pub fn emit_in(&self, scope: &Scope, name: &str, payload: Value)

Runs every handler registered for name through the scope’s defer, in the emitting request’s wait_until, and forwards the event to every mounted sidecar (ADR 0017). Never fails the request; handler errors are logged with the event name. An emission nothing heard — no local handler and nothing forwarded — is warned about: the silent delivery this issue was written to prevent.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for EventBus

fn default() -> EventBus

Returns the “default value” for a type.