Struct ThresholdLoadBalancer 

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

Threshold-based load balancer that limits allocations per entry and handles failures.

Implementations

impl<T> ThresholdLoadBalancer<T>

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

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

Create a new threshold load balancer with a fixed 1-second interval.

Arguments

• entries - A vector of tuples (max_count, max_error_count, value):
  • max_count: Maximum number of allocations allowed per interval.
  • max_error_count: Maximum number of errors allowed before disabling the entry.
  • value: value.

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

Create a new threshold load balancer with a custom interval.

Arguments

• entries - A vector of tuples (max_count, max_error_count, value):

  • max_count: Maximum number of allocations allowed per interval.
  • max_error_count: Maximum number of errors allowed before disabling the entry.
  • value: value.

• interval - Duration after which all allocation/error counts are reset.

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

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

Execute a custom async update on the internal reference.

pub async fn alloc_skip(&self, skip_index: usize) -> (usize, T)

Allocate an entry, skipping the specified index if provided.

pub fn try_alloc_skip(&self, skip_index: usize) -> Option<(usize, T)>

Try to allocate an entry immediately, skipping the specified index if provided.

pub fn success(&self, index: usize)

Mark a successful usage for the entry at the given index.

pub fn failure(&self, index: usize)

Mark a failure for the entry at the given index.

Trait Implementations

impl<T> BoxLoadBalancer<T> for ThresholdLoadBalancer<T>

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

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

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

Allocate an entry asynchronously.

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

Attempt to allocate an entry immediately.

impl<T> Clone for ThresholdLoadBalancer<T>

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> LoadBalancer<T> for ThresholdLoadBalancer<T>

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

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

Allocate an entry asynchronously.

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

Attempt to allocate an entry immediately.