Struct Spawner 

pub struct Spawner { /* private fields */ }

Agent-agnostic process spawner with tracking and log capture.

Manages the full lifecycle: claim → spawn → track → complete/release.

Implementations

impl Spawner

pub fn new() -> Self

Create an empty spawner with no running agents.

pub fn spawn( &mut self, unit_id: &str, unit_title: &str, action: AgentAction, config: &Config, mana_dir: Option<&Path>, ) -> Result<()>

Spawn an agent for a unit.

1. Selects the command template from config (run or plan)
2. Substitutes {id} with the unit ID
3. Claims the unit via mana claim
4. Opens a log file for stdout/stderr capture
5. Spawns the process via sh -c <cmd>
6. Registers the process in the agents persistence file

pub fn check_completed(&mut self) -> Vec<CompletedAgent>

Non-blocking check for completed agents.

Calls try_wait() on each running process. Completed agents are removed from the running map and returned. On failure, the unit claim is released.

pub fn running_count(&self) -> usize

Number of currently running agents.

pub fn can_spawn(&self, max_concurrent: u32) -> bool

Whether a new agent can be spawned given the concurrency limit.

pub fn list_running(&self) -> Vec<&AgentProcess>

Immutable view of all running agent processes.

pub fn kill_all(&mut self)

Kill all running agent processes and release their claims.

pub fn shutdown_all(&mut self, grace_period: Duration)

Gracefully shutdown all running agent processes.

Sends SIGTERM first, waits up to grace_period for processes to exit, then falls back to SIGKILL for any remaining. Releases claims on all affected units.

Trait Implementations

impl Default for Spawner

fn default() -> Self

Returns the “default value” for a type.