Struct sozu_lib::PeakEWMA

pub struct PeakEWMA {
    pub decay: f64,
    pub rtt: f64,
    pub last_event: Instant,
}

exponentially weighted moving average with high sensibility to latency bursts

cf Finagle for the original implementation: https://github.com/twitter/finagle/blob/9cc08d15216497bb03a1cafda96b7266cfbbcff1/finagle-core/src/main/scala/com/twitter/finagle/loadbalancer/PeakEwma.scala

Fields

decay: f64

decay in nanoseconds

higher values will make the EWMA decay slowly to 0

rtt: f64

estimated RTT in nanoseconds

must be set to a high enough default value so that new backends do not get all the traffic right away

last_event: Instant

last modification

Implementations

impl PeakEWMA

pub fn new() -> Self

pub fn observe(&mut self, rtt: f64)

pub fn get(&mut self, active_requests: usize) -> f64

Trait Implementations

impl Clone for PeakEWMA

fn clone(&self) -> PeakEWMA

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PeakEWMA

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

Formats the value using the given formatter.

impl Default for PeakEWMA

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq<PeakEWMA> for PeakEWMA

fn eq(&self, other: &PeakEWMA) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PeakEWMA