Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

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

Implementations

impl WorkerRegistry

pub fn new() -> Self

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

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 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)

Prune workers that haven’t sent a heartbeat within the timeout.

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.