Struct AgentOrchestrator 

pub struct AgentOrchestrator { /* private fields */ }

Orchestrator for running agents via OpenCode Server

Implementations

impl AgentOrchestrator

pub async fn new(event_tx: Sender<AgentEvent>) -> Result<Self>

Create a new orchestrator

pub fn with_manager( manager: Arc<OpenCodeManager>, event_tx: Sender<AgentEvent>, ) -> Self

Create with a custom manager (for testing)

pub async fn spawn_agent( &mut self, task: &Task, tag: &str, prompt: &str, model: Option<(&str, &str)>, ) -> Result<AgentHandle>

Spawn an agent for a task

pub async fn cancel_agent(&mut self, task_id: &str) -> Result<()>

Cancel a running agent

pub fn active_tasks(&self) -> Vec<String>

Get all active task IDs

pub fn is_task_active(&self, task_id: &str) -> bool

Check if a task has an active session

pub fn active_count(&self) -> usize

Get the number of active sessions

pub async fn process_event( &mut self, event: OpenCodeEvent, ) -> Option<AgentEvent>

Process an OpenCode event and emit corresponding AgentEvent

pub async fn wait_all(&mut self) -> Vec<AgentResult>

Wait for all agents to complete

pub async fn cleanup(&mut self)

Clean up all sessions