Struct ElasticObjectPool 

pub struct ElasticObjectPool<T: Poolable> { /* private fields */ }

An elastic object pool.

Pools are configured with a minimum and maximum size, and allocate the minimum number of items up front. When an item is requested and the pool is empty, but has not yet reached its maximum size, it will allocate the item on demand.

Periodically, a background task will evaluate the utilization of the pool and shrink the pool size in order to attempt to size it more closely to the recent demand. The frequency of this shrinking, as well as how usage demand is captured and rolled off, is configurable.

Missing

• Actual configurability around the shrinking frequency and usage demand roll-off.

Implementations

impl<T> ElasticObjectPool<T>

where T: Poolable + 'static, T::Data: Default,

pub fn with_capacity<S>( pool_name: S, min_capacity: usize, max_capacity: usize, ) -> (Self, impl Future<Output = ()>)

where S: Into<String>,

Creates a new ElasticObjectPool with the given minimum and maximum capacity.

impl<T> ElasticObjectPool<T>

where T: Poolable + 'static,

pub fn with_builder<S, B>( pool_name: S, min_capacity: usize, max_capacity: usize, builder: B, ) -> (Self, impl Future<Output = ()>)

where S: Into<String>, B: Fn() -> T::Data + Send + Sync + 'static,

Creates a new ElasticObjectPool with the given minimum and maximum capacity and item builder.

builder is called to construct each item.

Trait Implementations

impl<T: Poolable> Clone for ElasticObjectPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> ObjectPool for ElasticObjectPool<T>

where T: Poolable + Send + Unpin + 'static,

type Item = T

The pooled value.

type AcquireFuture = ElasticAcquireFuture<T>

Type of future returned by acquire.

fn acquire(&self) -> Self::AcquireFuture

Acquires an item from the object pool.