Struct TimeLoadBalancer 

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

A load balancer that allocates items based on a fixed interval. Each entry can only be reused after its interval has elapsed since the last allocation.

Implementations

impl<T> TimeLoadBalancer<T>

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

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

Create a new IntervalLoadBalancer with a list of (interval, value) pairs. Each value will only be available after its interval has passed since the last allocation.

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

where F: Fn(Arc<RwLock<Vec<Entry<T>>>>) -> R, R: Future<Output = Result<N>>,

Update the internal entries using an async callback. This allows dynamic reconfiguration of the load balancer.

Trait Implementations

impl<T> BoxLoadBalancer<T> for TimeLoadBalancer<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,

Asynchronous allocation (boxed trait version).

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

Immediate allocation attempt (boxed trait version).

impl<T> Clone for TimeLoadBalancer<T>

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> LoadBalancer<T> for TimeLoadBalancer<T>

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

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

Allocate a value asynchronously. This will loop until a value becomes available, yielding in between attempts.

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

Try to allocate a value immediately without waiting. Returns Some(value) if an entry is available (interval elapsed), otherwise returns None.