Struct InProcessBus 

pub struct InProcessBus { /* private fields */ }

In-process broadcast bus — the standalone implementation.

Implementations

impl InProcessBus

pub fn new(capacity: usize) -> Self

A bus buffering up to capacity events for slow subscribers.

Trait Implementations

impl EventBus for InProcessBus

fn publish(&self, event: FleetEvent)

Fan an event out to current subscribers. Never blocks on slow/absent receivers (delivery is best-effort relative to the durable store).

fn subscribe(&self, stream_key: &str) -> BusSubscription

A live subscription to one stream’s events. The returned stream yields only events whose stream key equals stream_key; consumers dedup the initial-history/live overlap on seq.

fn subscribe_all(&self) -> BusSubscription

A live subscription to EVERY stream’s events, unfiltered. Needed by fleet-wide watchers (e.g. FleetManager::watch_changes) that can’t name a stream key in advance — a brand-new agent’s own id keys its AgentDiscovered event, so no one can pre-subscribe to it by key.