Struct MetricsHub 

pub struct MetricsHub {
    queries: Mutex<VecDeque<QueryTrace>>,
    histogram: Mutex<Histogram>,
    usn: Mutex<VecDeque<UsnTrace>>,
    scans: Mutex<VecDeque<ScanTrace>>,
    pub counters: Counters,
}

Thread-safe metrics collector owned by the engine.

Fields

queries: Mutex<VecDeque<QueryTrace>>

histogram: Mutex<Histogram>

usn: Mutex<VecDeque<UsnTrace>>

scans: Mutex<VecDeque<ScanTrace>>

counters: Counters

Process-wide degradation counters.

Implementations

impl MetricsHub

pub fn new() -> Self

Create an empty hub with a fresh 32-bucket histogram.

pub fn record_query(&self, trace: QueryTrace)

Record a query trace into the ring and its latency into the histogram.

pub fn record_usn(&self, trace: UsnTrace)

Record a USN-batch trace into the ring.

pub fn record_scan(&self, trace: ScanTrace)

Record an index-established (scan/snapshot) trace into the ring.

pub fn last_query(&self) -> Option<QueryTrace>

The most recently recorded query trace, if any.

pub fn snapshot( &self, recent: usize, indexes: Vec<IndexStats>, ) -> MetricsSnapshot

Snapshot with the most recent recent queries (newest last).

Trait Implementations

impl Default for MetricsHub

fn default() -> MetricsHub

Returns the “default value” for a type.