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 with_turn_middlewares( provider: Arc<dyn Provider>, tools: ToolRegistry, turn_middlewares: Vec<Arc<dyn TurnMiddleware>>, config: OrchestratorConfig, ) -> Self

pub fn with_lifecycle_hooks(self, hooks: Vec<Arc<dyn LifecycleHook>>) -> Self

Set lifecycle hooks for this orchestrator.

Lifecycle hooks are fire-and-forget observers that cannot block or transform the agent loop. They are called at key points (session start/end, pre/post tool call, pre/post LLM call) for telemetry, billing, and notification use-cases.

pub fn add_lifecycle_hook(&mut self, hook: Arc<dyn LifecycleHook>)

Add a single lifecycle hook to this orchestrator.

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

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

pub fn provider_name(&self) -> Result<String, CoreError>

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.