Struct EventBus 

pub struct EventBus { /* private fields */ }

Shared event bus for broadcasting repo events to watching agents.

Uses per-repo tokio::sync::broadcast channels so subscribers only receive events for repos they care about. A special “all” channel receives a copy of every published event (used by the platform bridge).

Events that are not consumed before the channel capacity (256) is exhausted are silently dropped for lagged receivers.

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus.

pub fn publish(&self, event: WatchEvent)

Publish an event to a specific repo channel AND the global “all” channel.

If there are no subscribers the event is silently discarded.

pub fn subscribe(&self, repo_id: &str) -> Receiver<WatchEvent>

Subscribe to events for a specific repo.

The receiver is created while the DashMap shard lock is held so that cleanup_idle cannot race and remove the channel between creation and subscription.

pub fn subscribe_all(&self) -> Receiver<WatchEvent>

Subscribe to ALL events across all repos (for the platform bridge).

pub fn remove_repo(&self, repo_id: &str)

Remove the channel for a specific repo (e.g. when decommissioned).

pub fn cleanup_idle(&self)

Remove channels that have no active receivers, excluding the global channel. Call periodically (e.g. every few minutes) to prevent unbounded growth.

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.