Struct AdaptivePool 

pub struct AdaptivePool { /* private fields */ }

Adaptive pool controller.

This is a controller — it recommends scaling decisions but does not itself spawn or kill tasks. The caller is responsible for acting on ScaleDecision values returned by AdaptivePool::evaluate.

Thread Safety

AdaptivePool is Send + Sync and may be shared across tasks.

Implementations

impl AdaptivePool

pub fn new(config: AdaptivePoolConfig, initial_workers: usize) -> Arc<Self>

Create a new pool controller with the given config and initial worker count.

pub async fn evaluate( &self, queue_depth: usize, latency_ms: f64, ) -> ScaleDecision

Feed a new observation and return a scaling recommendation.

Call this on each pipeline tick (e.g. every 500 ms) to get decisions.

Arguments

• queue_depth — raw queue depth observation (number of queued items).
• latency_ms — recent P99 or average latency in milliseconds.

pub async fn set_workers(&self, count: usize)

Notify the controller that the worker count changed externally.

pub async fn stats(&self) -> PoolStats

Return a statistics snapshot.

pub fn observation_count(&self) -> usize

Total number of observations fed.