Struct MessageRouter 

pub struct MessageRouter { /* private fields */ }

The messaging router handles delivery of inter-agent messages.

Implementations

impl MessageRouter

pub fn new() -> Self

Create a new message router.

pub fn register(&self, fighter_id: FighterId) -> Receiver<AgentMessage>

Register a fighter’s mailbox. Returns a receiver for the fighter to consume messages from.

pub fn unregister(&self, fighter_id: &FighterId)

Unregister a fighter’s mailbox.

pub fn is_registered(&self, fighter_id: &FighterId) -> bool

Check if a fighter has a registered mailbox.

pub async fn send_direct( &self, from: FighterId, to: FighterId, content: AgentMessageType, priority: MessagePriority, ) -> PunchResult<Uuid>

Send a direct message from one fighter to another.

pub async fn broadcast( &self, from: FighterId, content: AgentMessageType, priority: MessagePriority, ) -> PunchResult<Vec<Uuid>>

Broadcast a message to all registered fighters (except the sender).

pub async fn multicast( &self, from: FighterId, targets: Vec<FighterId>, content: AgentMessageType, priority: MessagePriority, ) -> PunchResult<Vec<Uuid>>

Multicast a message to a specific set of fighters.

pub async fn request( &self, from: FighterId, to: FighterId, content: AgentMessageType, timeout: Duration, ) -> PunchResult<AgentMessage>

Send a request and wait for a response with timeout.

Returns the response message on success, or a timeout error.

pub fn respond( &self, original_msg_id: &Uuid, response: AgentMessage, ) -> PunchResult<()>

Respond to a request message.

pub fn dead_letter_count(&self) -> usize

Get the count of dead letters.

pub fn drain_dead_letters(&self) -> Vec<AgentMessage>

Drain all dead letters.

pub fn registered_count(&self) -> usize

Get the number of registered mailboxes.

Trait Implementations

impl Default for MessageRouter

fn default() -> Self

Returns the “default value” for a type.