Struct SwarmHealthMonitor 

pub struct SwarmHealthMonitor { /* private fields */ }

Swarm health monitor — tracks worker health, detects failures, and provides aggregate telemetry.

Heartbeat Protocol

Workers send heartbeats at regular intervals. If a worker misses max_missed_beats consecutive heartbeats, it is marked as Unhealthy. After max_missed_beats * 2 missed beats, it is marked as Dead.

Dead-Agent Detection

The health monitor periodically scans all tracked workers. Workers that have been Dead for longer than replacement_timeout_secs are candidates for automatic replacement.

Metrics

The monitor tracks task throughput, worker utilization, error rates, and communication latency. These are exposed via metrics().

Implementations

impl SwarmHealthMonitor

pub fn new( heartbeat_interval_secs: u64, max_missed_beats: u32, replacement_timeout_secs: u64, ) -> Self

Create a new health monitor with custom parameters.

pub fn register_worker(&mut self, role: &str)

Register a new worker for health tracking.

pub fn heartbeat(&mut self, role: &str)

Record a heartbeat from a worker.

pub fn task_started(&mut self, role: &str)

Record that a worker started a task.

pub fn task_completed(&mut self, role: &str)

Record that a worker completed a task successfully.

pub fn task_failed(&mut self, role: &str)

Record that a worker’s task failed.

pub fn record_error(&mut self, role: &str)

Record an error from a worker.

pub fn message_sent(&mut self, role: &str)

Record a message sent by a worker.

pub fn message_received(&mut self, role: &str)

Record a message received by a worker.

pub fn check_health(&mut self) -> Vec<String>

Scan all workers and update their health status based on heartbeat timing. Returns a list of workers that have been detected as dead.

pub fn worker_telemetry(&self, role: &str) -> Option<WorkerTelemetry>

Get telemetry for a specific worker.

pub fn all_worker_telemetry(&self) -> Vec<WorkerTelemetry>

Get telemetry for all workers.

pub fn metrics(&self) -> SwarmMetrics

Get aggregate swarm metrics.

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

Get workers that are candidates for replacement (dead for > replacement_timeout).

pub fn remove_worker(&mut self, role: &str)

Remove a worker from tracking (after replacement).

pub fn worker_count(&self) -> usize

Get the number of tracked workers.

pub fn format_status(&self) -> String

Format health status for logging.

Trait Implementations

impl Clone for SwarmHealthMonitor

fn clone(&self) -> SwarmHealthMonitor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SwarmHealthMonitor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SwarmHealthMonitor

fn default() -> Self

Returns the “default value” for a type.