Struct LagMeter 

pub struct LagMeter { /* private fields */ }

Shared latency record for one sequencer’s writer thread.

Written by the writer, read and drained by the daemon. Deliberately a plain observation surface with no policy of its own: what a node does about a breach (write a file, page someone, refuse traffic) is an operator decision, the same reasoning that keeps SequencerHandle::durability_failed an observation rather than an action.

Implementations

impl LagMeter

pub fn new() -> Self

A meter gated at DEFAULT_GATE.

pub fn gate(&self) -> Duration

The latency at or above which an op is recorded as a breach.

pub fn set_gate(&self, gate: Duration)

Moves the gate. Live rather than construction-time so a gate can be tightened against a running node, and so a test can prove the check is capable of failing.

pub fn record( &self, seq: u64, decision: Duration, durable: Duration, batch: usize, )

Records one accepted op.

pub fn drain(&self) -> (Vec<Breach>, u64)

Takes the breaches recorded since the last drain, and how many were dropped from the ring before this drain could reach them.

pub fn report(&self) -> LagReport

A point-in-time summary since process start.

Trait Implementations

impl Debug for LagMeter

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

Formats the value using the given formatter.

impl Default for LagMeter

fn default() -> Self

Returns the “default value” for a type.