Struct MonitorCore 

pub struct MonitorCore { /* private fields */ }

The monitor’s shareable core: ingest on one side, events + snapshots on the other. Session wiring lives in Monitor; the core is pure and deterministically testable.

Implementations

impl MonitorCore

pub fn new(capacity: usize) -> Arc<MonitorCore>

pub fn bounded(capacity: usize, max_keys: usize) -> Arc<MonitorCore>

A core whose statistics table is bounded at max_keys distinct keys.

pub fn ingest(&self, view: SampleView, sn: Option<u32>)

Ingest one sample: stats update + broadcast. Hot path — one lock, no tree work (that happens on the tick).

pub fn node_event(&self, key: String, up: bool)

pub fn tick(&self)

Rebuild the snapshot from the stats and announce it.

pub fn tree(&self) -> Arc<KeyTreeSnapshot>

The latest immutable snapshot (lock-free pull).

pub fn with_stats<R>(&self, f: impl FnOnce(&StatsTable) -> R) -> R

Read access to the raw stats (hz/bw commands).

pub fn with_stats_mut<R>(&self, f: impl FnOnce(&mut StatsTable) -> R) -> R

Mutable access — watch retirement and tests.

pub fn keys_unwatched(&self) -> u64

Keys retired from the table because their watch was released (RFC 09 §5.1 O6 — see crate::stats::StatsTable::unwatched).

pub fn dropped(&self) -> u64

Total events dropped across all lagging receivers so far.

pub fn keys_evicted(&self) -> u64

Distinct keys dropped from the statistics table to stay within its bound. Non-zero means the key set on display is partial — report it rather than letting a shrinking tree read as a quieting bus (RFC 09 §5.1).

pub fn events(self: &Arc<Self>) -> EventStream

Subscribe to the event stream.