Struct WorkerPool 

pub struct WorkerPool<Req, Resp> {
    pub policy: DispatchPolicy,
    /* private fields */
}

Pool of workers. Generic over (Req, Resp); works with the Worker trait directly.

Fields

policy: DispatchPolicy

Implementations

impl<Req, Resp> WorkerPool<Req, Resp>

pub fn new(policy: DispatchPolicy) -> Self

pub fn add(&mut self, worker: Arc<dyn Worker<Req, Resp>>)

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn select(&self) -> Option<&Arc<dyn Worker<Req, Resp>>>

Pick a worker per policy.

pub fn dispatch(&self, req: Req) -> Result<Resp, WorkerError>

Dispatch a request through the chosen worker.

pub fn health(&self) -> Vec<(WorkerId, WorkerHealth)>

Snapshot of every worker’s health.