Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Pool of connected workers with capacity-aware task routing.

Implementations

impl WorkerPool

pub fn new(heartbeat_timeout_ms: u64) -> Self

pub fn register(&self, info: WorkerInfo)

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

pub fn heartbeat(&self, worker_id: &str, active_tasks: u32)

pub fn select_and_reserve(&self, task_type: &str) -> Option<String>

Atomically selects a worker and reserves capacity. Returns the worker ID if one is available, or None. This avoids the TOCTOU race between select and dispatch.

pub fn select_worker(&self, task_type: &str) -> Option<String>

Selects the least-loaded worker for a task type WITHOUT modifying state. Use select_and_reserve for dispatch to avoid TOCTOU races.

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

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

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

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

pub fn count(&self) -> usize

pub fn stats(&self) -> PoolStats