Struct AgentOrchestrator 

pub struct AgentOrchestrator { /* private fields */ }

Agent Orchestrator - 主子智能体协调器

基于事件总线实现统一的监控和控制机制。 默认使用内存事件通讯，支持用户自定义 NATS provider。

Implementations

impl AgentOrchestrator

pub fn new_memory() -> Self

创建新的 orchestrator（使用内存事件通讯）

这是默认的创建方式，适用于单进程场景。

pub fn new(config: OrchestratorConfig) -> Self

使用自定义配置创建 orchestrator

pub fn subscribe_all(&self) -> Receiver<OrchestratorEvent>

订阅所有 SubAgent 事件

返回一个接收器，可以接收所有 SubAgent 的事件。

pub fn subscribe_subagent(&self, id: &str) -> SubAgentEventStream

订阅特定 SubAgent 的事件

返回一个过滤后的接收器，只接收指定 SubAgent 的事件。

pub async fn spawn_subagent( &self, config: SubAgentConfig, ) -> Result<SubAgentHandle>

启动新的 SubAgent

返回 SubAgent 句柄，可用于控制和查询状态。

pub async fn send_control(&self, id: &str, signal: ControlSignal) -> Result<()>

发送控制信号到 SubAgent

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

暂停 SubAgent

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

恢复 SubAgent

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

取消 SubAgent

pub async fn adjust_subagent_params( &self, id: &str, max_steps: Option<usize>, timeout_ms: Option<u64>, ) -> Result<()>

调整 SubAgent 参数

pub async fn get_subagent_state(&self, id: &str) -> Option<SubAgentState>

获取 SubAgent 状态

pub async fn get_all_states(&self) -> HashMap<String, SubAgentState>

获取所有 SubAgent 的状态

pub async fn active_count(&self) -> usize

获取活跃的 SubAgent 数量

pub async fn wait_all(&self) -> Result<()>

等待所有 SubAgent 完成

pub async fn list_subagents(&self) -> Vec<SubAgentInfo>

获取所有 SubAgent 的信息列表

pub async fn get_subagent_info(&self, id: &str) -> Option<SubAgentInfo>

获取特定 SubAgent 的详细信息

pub async fn get_active_activities(&self) -> HashMap<String, SubAgentActivity>

获取所有活跃 SubAgent 的当前活动

pub async fn get_handle(&self, id: &str) -> Option<SubAgentHandle>

获取 SubAgent 句柄（用于直接控制）

Trait Implementations

impl Debug for AgentOrchestrator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.