Struct KeyStats 

pub struct KeyStats {
    pub count: u64,
    pub bytes: u64,
    pub rate_hz: f64,
    pub last_seen: Instant,
    pub sn_gaps: u64,
    pub sn_resets: u64,
    pub unstamped: u64,
    /* private fields */
}

One key’s running statistics.

Fields

count: u64

bytes: u64

rate_hz: f64

EWMA of the instantaneous rate (Hz), time-decayed.

last_seen: Instant

sn_gaps: u64

Consecutive source-sequence-number gap count, when publishers attach SourceInfo (unstable API) — loss visibility, --loss. Wrap-safe: the SN is a u32, so u32::MAX → 0 is the next sample, not a 4-billion-sample gap (see the private SN_RESET_WINDOW).

sn_resets: u64

Times the sequence numbering restarted — a backwards or absurd jump (beyond the private SN_RESET_WINDOW), which is a publisher restart, not loss. Its own number: folding a restart into sn_gaps would invent millions of “lost” samples nobody sent (RFC 09 §5.1 O6 — the kinds are never folded).

unstamped: u64

Samples that carried no HLC timestamp — an observation of their own, counted separately: an unstamped sample has no latency, which is not the same as zero latency (#119).

Implementations

impl KeyStats

pub fn latency(&self) -> Option<LatencyReport>

The window’s distributions, split by who stamped them (#213).

None before any stamped sample — which is not zero latency, and is why KeyStats::unstamped is counted beside this rather than folded into it.

Trait Implementations

impl Clone for KeyStats

fn clone(&self) -> KeyStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KeyStats

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

Formats the value using the given formatter.