Struct Orchestrator 

pub struct Orchestrator { /* private fields */ }

The orchestrator coordinates the full Ouroboros lifecycle.

Implementations

impl Orchestrator

pub fn new( ouroboros: Arc<dyn OuroborosProtocol>, event_bus: EventBus, state_store: Arc<StateStore>, lifecycle: AgentLifecycleManager, ) -> Self

Creates a new orchestrator.

pub fn with_config( ouroboros: Arc<dyn OuroborosProtocol>, event_bus: EventBus, state_store: Arc<StateStore>, lifecycle: AgentLifecycleManager, config: OrchestratorConfig, ) -> Self

Creates a new orchestrator with custom config.

pub fn set_space_manager(&self, manager: Arc<SpaceManager>)

Set the SpaceManager for context partitioning.

pub fn current_space_id(&self) -> Option<SpaceId>

Get the current Space ID, if SpaceManager is set.

pub fn current_space_tag(&self) -> String

Get the current Space name tag for response decoration.

pub fn set_a2a(&mut self, a2a: Arc<A2AProtocol>)

Set the A2A protocol for inter-agent task delegation.

pub fn set_git_layer(&mut self, git_layer: Arc<GitLayer>)

Set the GitLayer for auto-commits after state saves.

pub async fn handle_message( &self, user_id: &str, user_message: &str, session_id: Option<&str>, ) -> Result<OrchestrationResult>

Handle a user message through the full Ouroboros loop.

Returns an OrchestrationResult with the response and metadata.

If the interview phase needs clarification (ambiguity > 0.2), the result will contain the questions and the phase will be Phase::Interview. The caller should send these questions to the user and include the session_id in follow-up messages.

pub async fn delegate_subtasks( &self, subtasks: Vec<SubTask>, parent_seed: &Seed, ) -> Result<Vec<SubTask>>

Execute multiple subtasks using separate agents in parallel.

When A2A is available, the orchestrator delegates tasks through the A2A protocol with circuit breaker and retry support. Otherwise, falls back to direct lifecycle execution.

Results are collected as they complete using JoinSet.