Struct CommunicationHub 

pub struct CommunicationHub { /* private fields */ }

Communication hub for managing multiple agent channels

Implementations

impl CommunicationHub

pub fn new() -> Self

Create a new communication hub

pub async fn register_agent(&self, agent_id: String) -> Result<()>

Register an agent with the hub

pub async fn unregister_agent(&self, agent_id: &str) -> Result<()>

Unregister an agent from the hub

pub async fn send_message( &self, from: String, to: String, message: AgentMessage, ) -> Result<()>

Send a message from one agent to another

pub async fn broadcast(&self, from: String, message: AgentMessage) -> Result<()>

Broadcast a message to all agents

pub async fn receive_message(&self, agent_id: &str) -> Option<MessageEnvelope>

Receive a message for a specific agent

pub async fn try_receive_message( &self, agent_id: &str, ) -> Option<MessageEnvelope>

Try to receive a message without blocking

pub async fn agent_count(&self) -> usize

Get the number of registered agents

pub async fn list_agents(&self) -> Vec<String>

Get list of registered agent IDs

pub async fn is_registered(&self, agent_id: &str) -> bool

Check if an agent is registered

Trait Implementations

impl Default for CommunicationHub

fn default() -> Self

Returns the “default value” for a type.