Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

A pool of workers for parallel event processing

Implementations

impl WorkerPool

pub fn new<F>(config: WorkerPoolConfig, processor: F) -> Self

where F: Fn(Event) + Send + Sync + Clone + 'static,

Create a new worker pool with the given configuration

pub async fn submit( &self, event: Event, partition_key: &str, ) -> Result<(), PoolBackpressureError>

Submit an event to the pool with a partition key

pub fn queue_depth(&self) -> usize

Get current queue depth

pub async fn metrics(&self) -> WorkerPoolMetrics

Get pool metrics

pub async fn worker_statuses(&self) -> Vec<WorkerStatus>

Get status of all workers

pub const fn config(&self) -> &WorkerPoolConfig

Get pool configuration

pub async fn shutdown(&mut self) -> Duration

Graceful shutdown

Trait Implementations

impl Debug for WorkerPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for WorkerPool

fn drop(&mut self)

Executes the destructor for this type.