Struct AgentOrchestrator 

pub struct AgentOrchestrator<M: OrchestratorAgentManager> { /* private fields */ }

Orchestrator for coordinating subagents and delegated task execution.

The orchestrator is core-owned and does not depend on Tauri. GUI/CLI layers can attach an OrchestratorObserver to receive lifecycle events.

Implementations

impl<M: OrchestratorAgentManager> AgentOrchestrator<M>

pub async fn list_environments( &self, run_id: Option<&str>, ) -> Vec<EnvironmentRecord>

pub async fn get_environment( &self, environment_id: &str, ) -> Option<EnvironmentRecord>

pub async fn retry_environment_preparation( &self, environment_id: &str, ) -> Result<EnvironmentRecord, String>

pub async fn cleanup_environment( &self, environment_id: &str, archive_if_dirty: bool, ) -> Result<EnvironmentRecord, String>

impl<M: OrchestratorAgentManager> AgentOrchestrator<M>

pub async fn reconcile_orchestrator_state(&self) -> Result<(), String>

impl<M: OrchestratorAgentManager> AgentOrchestrator<M>

pub fn new(agent_manager: M, config: AppConfig) -> Self

Create a new orchestrator with the given agent manager and application config.

pub fn new_with_workspace_root( agent_manager: M, config: AppConfig, default_workspace_dir: Option<PathBuf>, ) -> Self

Create a new orchestrator with an explicit workspace root for persisted state.

pub async fn set_observer(&self, observer: Arc<dyn OrchestratorObserver>)

Attach an observer used for adapter-side event emission.

This is intentionally async and uses interior mutability so adapters (GUI/CLI) can attach observers after construction (e.g., once a Tauri AppHandle exists) without requiring &mut self.

pub async fn clear_observer(&self)

Remove any attached observer.

pub async fn spawn_subagent(&self, id: &str, name: &str) -> Result<(), String>

Spawn and register a new subagent.

pub async fn spawn_subagent_with_request( &self, request: AgentSpawnRequest, ) -> Result<(), String>

Spawn and register a subagent using an explicit specialist configuration.

pub async fn delegate_task(&self, task: DelegatedTask) -> Result<String, String>

Delegate a task to a subagent.

• Ensures the target agent exists (spawning a default one if needed)
• Enforces tool permission checks
• Executes the task asynchronously via the unified pipeline

pub async fn create_child_supervisor_run( &self, request: ChildSupervisorRunRequest, ) -> Result<SupervisorRun, String>

Create a direct child supervisor run under an existing parent run.

pub async fn poll_result(&self) -> Option<TaskResult>

Get the result of a completed task if one is ready.

pub async fn list_active_tasks(&self) -> Vec<DelegatedTask>

Get list of currently active tasks.

pub async fn list_active_task_snapshots(&self) -> Vec<ActiveTaskSnapshot>

Get live active-task snapshots enriched with mirrored execution telemetry.

pub async fn list_supervisor_runs(&self) -> Vec<SupervisorRun>

List live and persisted supervisor runs known to the orchestrator.

pub async fn list_root_supervisor_runs(&self) -> Vec<SupervisorRun>

List only root supervisor runs (child runs excluded from the top-level list).

pub async fn list_child_supervisor_runs( &self, parent_run_id: &str, ) -> Vec<SupervisorRun>

List child supervisor runs for a specific parent run.

pub async fn get_supervisor_run_ancestry( &self, run_id: &str, ) -> Vec<SupervisorRun>

Return the ancestor chain for a run, ordered from root to immediate parent.

pub async fn get_supervisor_run_descendants( &self, run_id: &str, ) -> Vec<SupervisorRun>

Return all descendants beneath a run (bounded to one level for now).

pub async fn list_supervisor_leaf_tasks( &self, run_id: &str, ) -> Vec<SupervisorTaskRecord>

Return leaf tasks visible beneath a run, including direct children.

pub async fn get_supervisor_run(&self, run_id: &str) -> Option<SupervisorRun>

Fetch a supervisor run by id.

pub async fn list_team_messages(&self, run_id: &str) -> Vec<TeamMessage>

List team messages for a run.

pub async fn list_team_threads(&self, run_id: &str) -> Vec<TeamThread>

List grouped collaboration threads for a run.

pub async fn list_team_threads_with_options( &self, run_id: &str, include_archived: bool, ) -> Vec<TeamThread>

List grouped collaboration threads for a run with archive controls.

pub async fn list_subagents(&self) -> Vec<AgentInfo>

List all running subagents.

pub async fn approve_task( &self, task_id: &str, actor: ApprovalActor, note: Option<String>, ) -> Result<(), String>

Approve a task before execution or after a review/test gate.

pub async fn reject_task( &self, task_id: &str, actor: ApprovalActor, note: Option<String>, ) -> Result<(), String>

Reject or request revision for a delegated task.

pub async fn retry_task(&self, task_id: &str) -> Result<(), String>

Retry a task that previously failed or was blocked.

pub async fn resume_task_from_checkpoint( &self, task_id: &str, ) -> Result<(), String>

Resume a blocked workflow task from its latest persisted checkpoint.

pub async fn restart_task_from_scratch( &self, task_id: &str, ) -> Result<(), String>

Restart a workflow task from scratch and discard any saved checkpoint resume state.

pub async fn acknowledge_blocked_task( &self, task_id: &str, note: Option<String>, ) -> Result<(), String>

Record that an operator acknowledged a blocked workflow task without resuming it.

pub async fn claim_task( &self, task_id: &str, agent_id: &str, ) -> Result<(), String>

Claim ownership of a queued task for an agent.

pub async fn send_team_message( &self, run_id: &str, task_id: Option<String>, kind: TeamMessageKind, sender_agent_id: Option<String>, recipient_agent_id: Option<String>, content: impl Into<String>, ) -> Result<TeamMessage, String>

Record a structured team message.

pub async fn send_team_message_draft( &self, run_id: &str, draft: TeamMessageDraft, ) -> Result<TeamMessage, String>

Record a structured collaboration message using the richer draft payload.

pub async fn update_team_thread_action( &self, run_id: &str, thread_id: &str, status: CollaborationActionStatus, actor_id: Option<String>, note: Option<String>, ) -> Result<TeamThread, String>

Update the latest actionable request in a collaboration thread.

pub async fn archive_team_thread( &self, run_id: &str, thread_id: &str, actor_id: Option<String>, note: Option<String>, ) -> Result<TeamThread, String>

Archive an existing collaboration thread.

pub async fn cancel_task(&self, task_id: &str) -> Result<(), String>

Cancel a running task.

pub async fn pause_task(&self, task_id: &str) -> Result<(), String>

Pause a running local delegated task and preserve resumable checkpoint state.

pub async fn shutdown_all(&self, grace_secs: u64)

Shutdown all subagents gracefully.

Trait Implementations

impl<M: Clone + OrchestratorAgentManager> Clone for AgentOrchestrator<M>

fn clone(&self) -> AgentOrchestrator<M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.