Struct ParallelOrchestrator 

pub struct ParallelOrchestrator { /* private fields */ }

Parallel orchestrator that executes agents concurrently

Implementations

impl ParallelOrchestrator

pub fn new() -> Self

Create a new parallel orchestrator

pub fn with_max_retries(self, max_retries: usize) -> Self

Set max retries per agent

pub fn with_parallel_limit(self, limit: usize) -> Self

Set parallel execution limit

Trait Implementations

impl Default for ParallelOrchestrator

fn default() -> Self

Returns the “default value” for a type.

impl Orchestrator for ParallelOrchestrator

fn name(&self) -> &str

Orchestrator name (must be unique)

fn description(&self) -> &str

Orchestrator description (what pattern it uses)

fn orchestrate<'life0, 'async_trait>( &'life0 self, agents: Vec<Box<dyn Agent>>, input: OrchestratorInput, ) -> Pin<Box<dyn Future<Output = Result<OrchestratorOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute orchestration with the provided agents and input