Struct AgentBus 

pub struct AgentBus {
    pub registry: Arc<AgentRegistry>,
    /* private fields */
}

The central in-process message bus.

Internally this is a tokio::sync::broadcast channel so every subscriber receives every message. Filtering by topic is done on the consumer side through BusHandle::subscribe_topic / BusHandle::recv_filtered.

Fields

registry: Arc<AgentRegistry>

Registry of connected agents

Implementations

impl AgentBus

pub fn new() -> Self

Create a new bus with default capacity.

pub fn with_capacity(capacity: usize) -> Self

Create a new bus with a specific channel capacity.

pub fn into_arc(self) -> Arc<Self>

Wrap self in an Arc for sharing across tasks.

pub fn handle(self: &Arc<Self>, agent_id: impl Into<String>) -> BusHandle

Create a BusHandle scoped to a specific agent.

pub fn publish(&self, envelope: BusEnvelope) -> usize

Publish an envelope directly (low-level).

pub fn receiver_count(&self) -> usize

Number of active receivers.

Trait Implementations

impl Default for AgentBus

fn default() -> Self

Returns the “default value” for a type.