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.
- Event
Bus - Unified event bus. Subscribe with
subscribe(), publish withsend(). 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.