Struct AgentManager 

pub struct AgentManager { /* private fields */ }

Agent Manager for spawning and managing agent lifecycles

Implementations

impl AgentManager

pub fn new( registry: Arc<SubagentRegistry>, orchestrator_config: OrchestratorConfig, ) -> Self

Create a new agent manager

pub async fn spawn_from_invocation( &self, invocation: ParsedInvocation, ) -> Result<Vec<Uuid>, SubagentError>

Spawn an agent from a parsed invocation

pub async fn spawn_agent( &self, agent_name: String, context: SubagentContext, ) -> Result<Uuid, SubagentError>

Spawn a single agent

pub async fn wait_for_agent( &self, agent_id: Uuid, ) -> Result<AgentResult, SubagentError>

Wait for an agent to complete

pub async fn cancel_agent(&self, agent_id: Uuid) -> Result<(), SubagentError>

Cancel an agent

pub async fn cancel_all(&self)

Cancel all active agents

pub async fn get_agent_status(&self, agent_id: Uuid) -> Option<SubagentStatus>

Get status of an agent

pub fn get_active_agents(&self) -> Vec<(Uuid, String, SubagentStatus)>

Get all active agents

pub async fn get_stats( &self, agent_name: Option<&str>, ) -> HashMap<String, AgentStats>

Get agent statistics

pub async fn handle_communication(&self) -> Result<(), SubagentError>

Handle agent communication via message bus

pub async fn inherit_context( &self, from_agent: Uuid, to_context: &mut SubagentContext, ) -> Result<(), SubagentError>

Support context inheritance between agents