Struct EventBus 

pub struct EventBus { /* private fields */ }

The live event sender plus its history buffer.

Cloning shares both halves. EventBus::install_hook makes this bus the destination of every observer built by create_observer; whoever owns the bus installs it once and holds the guard for as long as it runs.

Implementations

impl EventBus

pub fn new() -> Self

A bus with the standard channel and history capacities.

pub fn with_capacities(channel: usize, history: usize) -> Self

A bus with explicit capacities (tests use small ones).

pub fn sender(&self) -> &Sender<Value>

The live sender. Other publishers (cron, heartbeat, the log layer) send on it directly; those frames are live-only and not buffered.

pub fn history(&self) -> &Arc<EventBuffer>

The history buffer the observer fills.

pub fn install_hook(&self) -> BroadcastHookGuard

Install this bus’s BroadcastObserver as the process-wide broadcast hook. The hook stays installed until the returned guard drops.

impl EventBus

pub fn shared_or_installed( shared: Option<Self>, ) -> (Self, Option<BroadcastHookGuard>)

The bus a component should publish on.

shared is a bus whose owner already installed its hook (a gateway under the daemon): it is reused and no second hook is installed, so each observer event reaches subscribers once and lands in one history. With no shared bus (a standalone gateway) a fresh bus is created and installed, and the caller holds the returned guard while it runs.

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() -> Self

Returns the “default value” for a type.