Struct Coordinator 

pub struct Coordinator { /* private fields */ }

Orchestrates multiple agent instances, routing messages and collecting results.

Implementations

impl Coordinator

pub fn new(cwd: PathBuf) -> Self

Create a new coordinator.

pub async fn spawn_agent( &self, agent_type: &str, name: Option<String>, ) -> Result<String, String>

Spawn an agent instance.

Returns the instance ID. The agent is created in Pending status and must be started with run_agent().

pub async fn run_agent( &self, agent_id: &str, prompt: &str, ) -> Result<AgentResult, String>

Run an agent with the given prompt.

Executes the agent as a subprocess and returns the result. The agent’s status is updated throughout the lifecycle.

pub async fn run_team(&self, tasks: Vec<(&str, &str, &str)>) -> Vec<AgentResult>

Run multiple agents in parallel and collect all results.

pub async fn send_message( &self, to: &str, from: &str, content: &str, ) -> Result<(), String>

Send a message to a running agent.

pub async fn list_agents(&self) -> Vec<AgentInstance>

List all agent instances.

pub fn registry(&self) -> &AgentRegistry

Get agent registry.

pub async fn create_team( &self, name: &str, agent_types: &[&str], ) -> Result<String, String>

Create a new team.

pub async fn list_teams(&self) -> Vec<Team>

List active teams.