Struct Random 

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

A load balancer that randomly selects an entry.

Implementations

impl<T> Random<T>

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

pub fn new(inner: Vec<T>) -> Self

Create a new random load balancer from a vector of values.

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

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

Update the inner entries using an async callback.

pub async fn update_timer<F, R>( &self, handler: F, interval: Duration, ) -> Result<JoinHandle<()>>

where F: Fn(Arc<RwLock<Vec<Entry<T>>>>) -> R + Send + Sync + 'static, R: Future<Output = Result<()>> + Send,

Spawn a background task that calls handler every interval.

Trait Implementations

impl<T> Clone for Random<T>

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> LoadBalancer<T> for Random<T>

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

async fn alloc(&self) -> T

Asynchronously allocate a random entry.

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

Try to allocate a random entry synchronously.