Struct Aimd 

pub struct Aimd { /* private fields */ }

Loss-based overload avoidance.

Additive-increase, multiplicative decrease.

Adds available currency when:

1. no load-based errors are observed, and
2. the utilisation of the current limit is high.

Reduces available concurrency by a factor when load-based errors are detected.

Implementations

impl Aimd

pub fn new_with_initial_limit(initial_limit: usize) -> Self

pub fn new(initial_limit: usize, limit_range: RangeInclusive<usize>) -> Self

pub fn decrease_factor(self, factor: f64) -> Self

Set the multiplier which will be applied when decreasing the limit.

pub fn increase_by(self, increase: usize) -> Self

Set the increment which will be applied when increasing the limit.

pub fn with_max_limit(self, max: usize) -> Self

pub fn with_min_utilisation_threshold(self, min_util: f64) -> Self

A threshold below which the limit won’t be increased. 0.5 = 50%.

Trait Implementations

impl Debug for Aimd

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl LimitAlgorithm for Aimd

fn limit(&self) -> usize

The current limit.

fn update<'life0, 'async_trait>( &'life0 self, sample: Sample, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

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

Update the concurrency limit in response to a new job completion.