Struct AgentOrchestrator 

pub struct AgentOrchestrator { /* private fields */ }

Agent orchestrator for managing and coordinating subagent execution

Implementations

impl AgentOrchestrator

pub fn new( registry: Arc<SubagentRegistry>, config: OrchestratorConfig, operating_mode: OperatingMode, ) -> Self

Create a new agent orchestrator

pub async fn execute_plan( &self, request: InvocationRequest, ) -> Result<OrchestratorResult, SubagentError>

Execute an invocation plan

pub async fn execute_single( &self, invocation: AgentInvocation, shared_context: &SharedContext, ) -> Result<SubagentExecution, SubagentError>

Execute a single agent

pub async fn execute_sequential( &self, chain: AgentChain, shared_context: &SharedContext, ) -> Result<Vec<SubagentExecution>, SubagentError>

Execute agents sequentially

pub async fn execute_parallel( &self, invocations: Vec<AgentInvocation>, shared_context: &SharedContext, ) -> Result<Vec<SubagentExecution>, SubagentError>

Execute agents in parallel

pub async fn execute_mixed( &self, steps: Vec<ExecutionStep>, shared_context: &SharedContext, ) -> Result<Vec<SubagentExecution>, SubagentError>

Execute mixed execution plan

pub async fn progress_receiver(&self) -> UnboundedReceiver<ProgressUpdate>

Get progress receiver

pub fn cancel(&self)

Cancel ongoing executions

pub fn reset_cancellation(&self)

Reset cancellation flag

pub fn active_count(&self) -> usize

Get active execution count

impl AgentOrchestrator

Conditional execution support

pub async fn execute_conditional<F>( &self, invocation: AgentInvocation, shared_context: &SharedContext, condition: F, ) -> Result<Option<SubagentExecution>, SubagentError>

where F: Fn(&SharedContext) -> BoxFuture<'_, bool> + Send + Sync,

Execute with conditional logic

pub async fn execute_with_dependencies( &self, invocation: AgentInvocation, dependencies: Vec<String>, shared_context: &SharedContext, ) -> Result<SubagentExecution, SubagentError>

Execute with dependencies

Trait Implementations

impl Debug for AgentOrchestrator

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

Formats the value using the given formatter.