Skip to main content

Module event_bus

Module event_bus 

Source
Expand description

Unified event bus — single tokio::broadcast channel for AgentEvents.

Allows Webhook/Trace/UI/Audit to subscribe to the same event stream, replacing the current scattered per-frontend event mapping.

Structs§

BusEvent
Wraps an AgentEvent with run context for multi-agent filtering.
EventBus
Unified event bus. Subscribe with subscribe(), publish with send(). Capacity 1024 to handle batch eval runs without dropping events.

Statics§

GLOBAL_EVENT_BUS
Global event bus — capacity 1024 to handle batch eval without dropping events. Subscribers that fall behind get RecvError::Lagged — consumers should handle this.