Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

The worker registry — tracks all known workers and their status.

Implementations

impl WorkerRegistry

pub fn new() -> Self

An empty registry with a 30-second heartbeat timeout — three missed beats at the workers’ 10-second cadence before a worker counts as dead.

pub fn with_heartbeat_timeout(self, secs: i64) -> Self

Override the heartbeat timeout (builder-style). Tests use 0 to make everything instantly stale and 3600 to make nothing stale.

pub fn register( &self, id: impl Into<String>, address: impl Into<String>, capabilities: Capabilities, )

Register a new worker or update an existing one.

pub fn heartbeat(&self, worker_id: &str, load: LoadMetrics)

Update a worker’s heartbeat and load metrics.

pub fn claim(&self, worker_id: &str, plan_id: impl Into<String>) -> bool

Record that plan_id has been placed on worker_id.

active_plans was initialised to vec![] and never touched again, so has_capacity and the “least loaded” tie-break both compared zeroes: placement picked an arbitrary worker and called it balanced. Returns false if the worker is unknown.

pub fn release(&self, worker_id: &str, plan_id: &str) -> bool

Release a plan, whether it finished or failed.

pub fn disconnect(&self, worker_id: &str)

Mark a worker as disconnected.

pub fn remove(&self, worker_id: &str)

Remove a worker entirely.

pub fn active_workers(&self) -> Vec<WorkerStatus>

Get all alive, connected workers.

pub fn get(&self, worker_id: &str) -> Option<WorkerStatus>

Get a specific worker by ID.

pub fn find_workers( &self, tags: &[String], max_concurrent: usize, ) -> Vec<WorkerStatus>

Find workers matching required tags with available capacity.

pub fn total_count(&self) -> usize

Total number of registered workers (including disconnected).

pub fn active_count(&self) -> usize

Number of alive, connected workers.

pub fn summary(&self) -> String

Human-readable summary.

pub fn prune_stale(&self) -> Vec<WorkerId>

Drop workers that have stopped sending heartbeats.

The predicate was is_alive(timeout) || w.connected, and is_alive already requires connected — so it reduced to w.connected and pruned nothing that was still marked connected, however long ago it had last been heard from. Which is the only case worth pruning. It also had no callers.

Returns the ids that were dropped, so a caller can log them.

Trait Implementations

impl Clone for WorkerRegistry

fn clone(&self) -> WorkerRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerRegistry

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

Formats the value using the given formatter.

impl Default for WorkerRegistry

fn default() -> Self

Returns the “default value” for a type.