Struct SwarmCoordinator 

pub struct SwarmCoordinator { /* private fields */ }

The swarm coordinator manages concurrent swarm tasks across available fighters.

Implementations

impl SwarmCoordinator

pub fn new() -> Self

Create a new swarm coordinator.

pub fn register_fighter(&self, fighter_id: FighterId)

Register a fighter as available for swarm work.

pub fn register_fighter_with_capabilities( &self, fighter_id: FighterId, capabilities: Vec<String>, )

Register a fighter with specific capabilities.

pub fn unregister_fighter(&self, fighter_id: &FighterId)

Remove a fighter from the available pool.

pub fn record_heartbeat(&self, fighter_id: &FighterId)

Record a heartbeat from a fighter to track liveness.

pub fn decompose_task(&self, description: &str) -> Vec<SwarmSubtask>

Decompose a task description into subtasks.

Uses intelligent splitting: tries paragraph breaks first, then sentence boundaries, then falls back to line-based splitting.

pub fn create_task(&self, description: String) -> Uuid

Create a new swarm task from a description.

The task is automatically decomposed into subtasks.

pub fn create_task_with_subtasks( &self, description: String, subtasks: Vec<SwarmSubtask>, ) -> Uuid

Create a swarm task with explicit subtasks (for pipeline or dependent tasks).

pub async fn assign_subtasks( &self, task_id: &Uuid, ) -> PunchResult<Vec<(Uuid, FighterId)>>

Assign pending subtasks to available fighters using load balancing and capability matching.

Returns a list of (subtask_id, fighter_id) assignments.

pub async fn complete_subtask( &self, task_id: &Uuid, subtask_id: &Uuid, result: String, ) -> PunchResult<()>

Report the completion of a subtask.

pub async fn fail_subtask( &self, task_id: &Uuid, subtask_id: &Uuid, error: String, ) -> PunchResult<()>

Report the failure of a subtask.

pub async fn reassign_failed_subtask( &self, task_id: &Uuid, subtask_id: &Uuid, ) -> PunchResult<Option<FighterId>>

Reassign a failed subtask to a different fighter.

pub fn detect_stale_fighters(&self) -> Vec<FighterId>

Detect stale or failed fighters and reassign their work.

Returns a list of fighter IDs that were detected as stale/failed.

pub fn mark_unhealthy(&self, fighter_id: &FighterId)

Mark a fighter as unhealthy (will not receive new assignments).

pub fn mark_healthy(&self, fighter_id: &FighterId)

Mark a fighter as healthy again.

pub async fn get_task(&self, task_id: &Uuid) -> Option<SwarmTask>

Get the current state of a swarm task.

pub async fn get_progress(&self, task_id: &Uuid) -> Option<f64>

Get the progress of a swarm task (0.0 to 1.0).

pub async fn get_progress_report( &self, task_id: &Uuid, ) -> Option<ProgressReport>

Get a detailed progress report for a swarm task.

pub fn list_task_ids(&self) -> Vec<Uuid>

List all active swarm task IDs.

pub fn available_fighter_count(&self) -> usize

Get the number of available healthy fighters.

pub fn get_fighter_loads(&self) -> Vec<FighterLoad>

Get load information for all fighters.

pub fn remove_task(&self, task_id: &Uuid) -> bool

Remove a completed or failed swarm task.

Trait Implementations

impl Default for SwarmCoordinator

fn default() -> Self

Returns the “default value” for a type.