Struct Aimd 

pub struct Aimd { /* private fields */ }

Loss-based request rate limiting.

Additive-increase, multiplicative decrease for requests per second.

Increases request rate when:

1. no overload errors are observed, and
2. requests are successful.

Reduces request rate by a factor when overload is detected.

Implementations

impl Aimd

pub fn new_with_initial_rate(initial_rps: u64) -> Self

pub fn new(initial_rps: u64, rate_range: RangeInclusive<u64>) -> Self

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

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

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

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

pub fn with_max_rate(self, max: u64) -> Self

Trait Implementations

impl Clone for Aimd

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Aimd

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

Formats the value using the given formatter.

impl RateLimitAlgorithm for Aimd

fn requests_per_second(&self) -> u64

The current requests per second limit.

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

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

Update the rate limit in response to a request completion.