Struct SimpleRuntime 

pub struct SimpleRuntime { /* private fields */ }

简单运行时 - 管理多个智能体的协同运行（非 dora 版本）

Implementations

impl SimpleRuntime

pub fn new() -> SimpleRuntime

创建新的简单运行时

pub async fn register_agent( &self, metadata: AgentMetadata, config: AgentConfig, role: &str, ) -> Result<Receiver<AgentEvent>, Error>

注册智能体

pub fn message_bus(&self) -> &Arc<SimpleMessageBus>

获取消息总线

pub async fn get_agents_by_role(&self, role: &str) -> Vec<String>

获取指定角色的智能体列表

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

发送消息给指定智能体

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

广播消息给所有智能体

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

发布到主题

pub async fn subscribe_topic( &self, agent_id: &str, topic: &str, ) -> Result<(), Error>

订阅主题

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

创建流

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

关闭流

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

订阅流

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

取消订阅流

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

发送流消息

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

暂停流

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

恢复流

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

获取流信息

pub async fn stop_all(&self) -> Result<(), Error>

停止所有智能体

Trait Implementations

impl Default for SimpleRuntime

Available on non-crate feature dora only.

fn default() -> SimpleRuntime

Returns the “default value” for a type.