Struct Lag 

pub(crate) struct Lag {
    pub(super) skipped: Option<u64>,
}

Logs an attach client which falls behind the output once until it caught up again, like LogErrors. A client which stays too slow skips messages again every time the channel filled up, which would log a warning for every one of its capacity of messages otherwise.

Fields

skipped: Option<u64>

The messages skipped since the client fell behind, none while it keeps up.

Implementations

impl Lag

pub(crate) fn skipped(&mut self, n: u64)

The client skipped n messages.

pub(crate) fn received<T>(&mut self, rx: &Receiver<T>)

The client received a message from rx. It caught up once nothing is queued for it anymore.

Trait Implementations

impl Debug for Lag

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

Formats the value using the given formatter.

impl Default for Lag

fn default() -> Self

Returns the “default value” for a type.