Struct WorkerPool 

pub struct WorkerPool<W, C, Q, RIS, MS, ES, LS, WISS, CS>
where
    W: Workflow<C, WorkItem: 'static>,
    C: Context + Merge + Default,
    Q: WorkQueue<C, W::WorkItem> + Send + Sync,
    RIS: RunInfoStore + Send + Sync,
    MS: MetricsStore + Send + Sync,
    ES: ErrorStore + Send + Sync,
    LS: LivenessStore + Send + Sync,
    WISS: WorkItemStateStore<W::WorkItem> + Send + Sync,
    CS: ContextStore<C> + Send + Sync + Clone + 'static,
{ /* private fields */ }

A pool of distributed workflow workers, each running in its own async task.

The pool manages worker lifecycles, graceful shutdown, and health reporting.

Implementations

impl<W, C, Q, RIS, MS, ES, LS, WISS, CS> WorkerPool<W, C, Q, RIS, MS, ES, LS, WISS, CS>

where W: Workflow<C, WorkItem: 'static> + 'static, C: Context + Merge + Default + 'static, Q: WorkQueue<C, W::WorkItem> + Send + Sync + Clone + 'static, RIS: RunInfoStore + Send + Sync + Clone + 'static, MS: MetricsStore + Send + Sync + Clone + 'static, ES: ErrorStore + Send + Sync + Clone + 'static, LS: LivenessStore + Send + Sync + Clone + 'static, WISS: WorkItemStateStore<W::WorkItem> + Send + Sync + Clone + 'static, CS: ContextStore<C> + Send + Sync + Clone + 'static,

pub fn new( worker: DistributedWorker<W, C, Q, RIS, MS, ES, LS, WISS, CS>, num_workers: usize, ) -> Self

Create a new worker pool with the given worker and number of workers.

pub fn start(&mut self)

Start all workers in the pool. Each worker runs in its own async task.

pub async fn stop(&mut self)

Gracefully stop all workers by signalling cancellation and waiting for them to finish.

pub async fn join(&mut self)

Wait for all workers to finish.

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

Get health/status of all workers from the liveness store.