Struct Orchestrator 

pub struct Orchestrator { /* private fields */ }

Implementations

impl Orchestrator

pub fn new( provider: Arc<dyn Provider>, tools: ToolRegistry, middlewares: Vec<Arc<dyn Middleware>>, config: OrchestratorConfig, ) -> Self

pub fn swap_provider(&self, new_provider: Arc<dyn Provider>) -> String

Swap the active provider at runtime. Returns the name of the new provider.

pub fn provider_name(&self) -> String

Get the current provider name.

pub fn run( &self, input: RunInput, event_handler: impl FnMut(AgentEvent), ) -> RunOutput

pub fn run_cancellable( &self, input: RunInput, cancel: Option<&Arc<AtomicBool>>, event_handler: impl FnMut(AgentEvent), ) -> RunOutput

Run the orchestrator loop with an optional cancellation flag.

If cancel is provided and set to true during execution, the loop will stop at the next iteration boundary.