Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

In-process worker pool with bounded queues and health-aware routing.

Implementations

impl WorkerPool

pub fn new_inprocess( handlers: Vec<Arc<dyn WorkerHandler>>, options: WorkerPoolOptions, hooks: Option<Arc<dyn CircuitBreakerHooks>>, ) -> Result<Self, WorkerPoolError>

Creates and starts an in-process worker pool.

pub async fn submit( &self, request: WorkerRequest, ) -> Result<WorkerResponse, WorkerPoolError>

Submits one request to the pool and waits for completion.

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

Returns current worker health snapshot.

pub async fn restart_worker( &self, worker_id: &str, ) -> Result<(), WorkerPoolError>

Restarts one worker task in place and resets health counters.

pub async fn shutdown(&self)

Gracefully shuts down all worker and probe tasks.

Trait Implementations

impl WorkerPoolClient for WorkerPool

fn submit<'life0, 'async_trait>( &'life0 self, request: WorkerRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkerResponse, WorkerPoolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits one request to the underlying worker pool.

fn health_snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<WorkerHealth>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns a snapshot of worker health state.