Struct SimpleMessageBus 

pub struct SimpleMessageBus { /* private fields */ }

简单消息总线

Implementations

impl SimpleMessageBus

pub fn new() -> Self

创建新的消息总线

pub async fn register(&self, agent_id: &str, tx: Sender<AgentEvent>)

注册智能体

pub async fn subscribe(&self, agent_id: &str, topic: &str)

订阅主题

pub async fn send_to(&self, target_id: &str, event: AgentEvent) -> Result<()>

发送点对点消息

pub async fn broadcast(&self, event: AgentEvent) -> Result<()>

广播消息给所有智能体

pub async fn publish(&self, topic: &str, event: AgentEvent) -> Result<()>

发布到主题

pub async fn create_stream( &self, stream_id: &str, stream_type: StreamType, metadata: HashMap<String, String>, ) -> Result<()>

创建流

pub async fn close_stream(&self, stream_id: &str, reason: &str) -> Result<()>

关闭流

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

订阅流

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

取消订阅流

pub async fn send_stream_message( &self, stream_id: &str, message: Vec<u8>, ) -> Result<()>

发送流消息

pub async fn pause_stream(&self, stream_id: &str) -> Result<()>

暂停流

pub async fn resume_stream(&self, stream_id: &str) -> Result<()>

恢复流

pub async fn get_stream_info( &self, stream_id: &str, ) -> Result<Option<StreamInfo>>

获取流信息

Trait Implementations

impl Default for SimpleMessageBus

Available on non-crate feature dora only.

fn default() -> Self

Returns the “default value” for a type.