Struct AgentOrchestrator 

pub struct AgentOrchestrator { /* private fields */ }

Advanced SubAgent control plane.

This API is for explicit SubAgent lifecycle control: spawn, pause, resume, cancel, inspect, and subscribe to events. Routine model-visible delegation should use task / parallel_task.

Implementations

impl AgentOrchestrator

pub fn new_memory() -> Self

Create a memory-backed control plane.

This is useful for inspecting an empty control plane in tests. Spawning SubAgents requires Self::from_agent.

pub fn new(config: OrchestratorConfig) -> Self

Create a memory-backed control plane with custom config.

pub fn from_agent(agent: Arc<Agent>) -> Self

Create an orchestrator backed by a real Agent for LLM execution.

SubAgents spawned by this orchestrator will run the actual agent definition (permissions, system prompt, model, max_steps) loaded from the agent’s configuration and any extra agent_dirs provided in SubAgentConfig.

pub fn from_agent_with_config( agent: Arc<Agent>, config: OrchestratorConfig, ) -> Self

Create an orchestrator backed by a real Agent with custom config.

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

Subscribe to all SubAgent events.

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

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

Subscribe to events for a specific SubAgent.

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

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

Spawn a new 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.