Struct AgentBus 

pub struct AgentBus { /* private fields */ }

通信总线核心结构体

Implementations

impl AgentBus

pub async fn new() -> Result<Self>

创建通信总线实例

pub async fn register_channel( &self, agent_metadata: &AgentMetadata, mode: CommunicationMode, ) -> Result<()>

为智能体注册通信通道

pub async fn send_message( &self, sender_id: &str, mode: CommunicationMode, message: &AgentMessage, ) -> Result<()>

pub async fn receive_message( &self, id: &str, mode: CommunicationMode, ) -> Result<Option<AgentMessage>>

pub async fn unsubscribe_topic(&self, id: &str, topic: &str) -> Result<()>

Trait Implementations

impl Clone for AgentBus

fn clone(&self) -> AgentBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.