Struct SubagentCoordinator 

pub struct SubagentCoordinator { /* private fields */ }

Subagent coordinator.

Wraps an AgentSupervisor to add lifecycle tracking, cancellation, and depth guarding. Owns the SubagentTracker registry.

Implementations

impl SubagentCoordinator

pub fn new(supervisor: AgentSupervisor) -> Self

Create a new coordinator with the default max depth (DEFAULT_MAX_SUBAGENT_DEPTH).

pub fn with_max_depth(supervisor: AgentSupervisor, max_depth: u32) -> Self

Create with an explicit max subagent nesting depth.

pub fn max_depth(&self) -> u32

Configured maximum nesting depth.

pub fn supervisor(&self) -> &AgentSupervisor

Borrow the wrapped supervisor (for direct spawns that bypass coordinator tracking).

pub fn tracked_count(&self) -> usize

Number of currently-tracked subagents (any state).

pub fn tracker(&self, agent_id: &str) -> Option<Arc<SubagentTracker>>

Look up a tracker by agent ID.

pub fn state(&self, agent_id: &str) -> Option<SubagentState>

Current state of an agent, or None if unknown.

pub fn snapshot(&self) -> HashMap<String, SubagentState>

Snapshot of every tracked agent ID → state.

pub fn spawn( &self, req: SubagentSpawnRequest, ) -> Result<String, SubagentCoordinatorError>

Spawn a subagent. Returns immediately with the agent ID on success — the run proceeds in a background task.

Errors:

• SubagentCoordinatorError::MaxDepthExceeded — req.depth exceeds Self::max_depth.
• SubagentCoordinatorError::DuplicateId — req.agent_id is already tracked.
• SubagentCoordinatorError::SpawnFailed — supervisor rejected the spawn (bad model/provider).
• SubagentCoordinatorError::ResumeFromNotFound — req.resume_from names an unknown agent.

pub fn cancel(&self, agent_id: &str) -> bool

Trigger cancellation for an agent. Returns true if the agent was tracked (and is now scheduled to transition to SubagentState::Cancelled).

pub async fn block_wait_slot( &self, agent_id: &str, timeout: Duration, ) -> Option<SubagentState>

Block until the named agent reaches a terminal state, or timeout elapses. Returns the terminal state on completion, None on timeout (the underlying run continues), or None if the agent is unknown.

This is the “block_wait_slot” operation from the design doc: on timeout the caller can either treat the agent as backgrounded (move on) or re-poll.

Trait Implementations

impl Clone for SubagentCoordinator

fn clone(&self) -> SubagentCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.