Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Worker pool manager.

Implementations

impl WorkerPool

pub fn new(config: WorkerPoolConfig) -> Self

Create a new worker pool.

pub fn with_defaults() -> Self

Create with default configuration.

pub fn register_worker(&self, worker: Worker) -> Result<WorkerId>

Register a new worker.

pub fn unregister_worker(&self, worker_id: WorkerId) -> Result<()>

Unregister a worker.

pub fn get_worker(&self, worker_id: WorkerId) -> Result<Arc<RwLock<Worker>>>

Get a worker by ID.

pub fn get_all_workers(&self) -> Vec<Arc<RwLock<Worker>>>

Get all workers.

pub fn get_workers_by_status( &self, status: WorkerStatus, ) -> Vec<Arc<RwLock<Worker>>>

Get workers by status.

pub fn heartbeat(&self, worker_id: WorkerId) -> Result<()>

Update worker heartbeat.

pub fn update_worker_usage( &self, worker_id: WorkerId, usage: WorkerUsage, ) -> Result<()>

Update worker resource usage.

pub fn check_worker_health(&self, worker_id: WorkerId) -> Result<bool>

Check worker health.

pub fn check_all_workers(&self) -> Result<Vec<WorkerId>>

Run health checks on all workers.

pub fn select_worker( &self, requirements: &ResourceRequirements, strategy: SelectionStrategy, ) -> Result<WorkerId>

Select a worker for task execution.

pub fn get_worker_metrics(&self, worker_id: WorkerId) -> Result<WorkerMetrics>

Get worker metrics.

pub fn get_statistics(&self) -> WorkerPoolStatistics

Get pool statistics.

pub fn drain_worker(&self, worker_id: WorkerId) -> Result<()>

Drain a worker (no new tasks).

pub fn resume_worker(&self, worker_id: WorkerId) -> Result<()>

Resume a drained worker.

pub fn get_worker_count(&self) -> usize

Get the current number of workers in the pool.

Trait Implementations

impl Clone for WorkerPool

fn clone(&self) -> WorkerPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.