Struct LimitLoadBalancer 

pub struct LimitLoadBalancer<T>
where
    T: Send + Sync + Clone + 'static,
{ /* private fields */ }

A load balancer that limits the number of allocations per entry over a specified time interval.

This implementation supports both async and sync allocation.

Implementations

impl<T> LimitLoadBalancer<T>

where T: Send + Sync + Clone + 'static,

pub fn new(entries: Vec<(u64, T)>) -> Self

Create a new LimitLoadBalancer with the default interval of 1 second.

pub fn new_interval(entries: Vec<(u64, T)>, interval: Duration) -> Self

Create a new LimitLoadBalancer with a custom interval duration.

pub async fn update<F, R>(&self, handle: F) -> Result<()>

where F: Fn(Arc<LimitLoadBalancerRef<T>>) -> R, R: Future<Output = Result<()>>,

Update the load balancer using an async callback.

Trait Implementations

impl<T> BoxLoadBalancer<T> for LimitLoadBalancer<T>

where T: Send + Sync + Clone + 'static,

fn alloc<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<T>> + Send + 'async_trait>>

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

Asynchronously allocate a resource from the load balancer. Returns Some(T) if an entry is available.

fn try_alloc(&self) -> Option<T>

Synchronously try to allocate a resource.

impl<T> Clone for LimitLoadBalancer<T>

where T: Send + Sync + Clone + 'static + Clone,

fn clone(&self) -> LimitLoadBalancer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> LoadBalancer<T> for LimitLoadBalancer<T>

where T: Send + Sync + Clone + 'static,

fn alloc(&self) -> impl Future<Output = Option<T>> + Send

Asynchronously allocate a resource from the load balancer. Returns Some(T) if an entry is available.

fn try_alloc(&self) -> Option<T>

Synchronously try to allocate a resource. Returns Some(T) if an entry is available.