codemem-core 0.19.0

Shared types, traits, and errors for the Codemem memory engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

//! Metrics trait and default no-op implementation for Codemem.

use std::collections::HashMap;

/// Trait for recording operational metrics.
pub trait Metrics: Send + Sync {
    /// Record a latency measurement for an operation.
    fn record_latency(&self, operation: &str, duration_ms: f64);

    /// Increment a named counter.
    fn increment_counter(&self, name: &str, delta: u64);

    /// Record a gauge (point-in-time) value.
    fn record_gauge(&self, name: &str, value: f64);
}

/// No-op metrics implementation (default).
pub struct NoopMetrics;

impl Metrics for NoopMetrics {
    fn record_latency(&self, _operation: &str, _duration_ms: f64) {}
    fn increment_counter(&self, _name: &str, _delta: u64) {}
    fn record_gauge(&self, _name: &str, _value: f64) {}
}

/// Snapshot of collected metrics.
#[derive(Debug, Clone, Default, serde::Serialize)]
pub struct MetricsSnapshot {
    /// Latency percentiles per operation (p50, p95, p99, count, total_ms).
    pub latencies: HashMap<String, LatencyStats>,
    /// Cumulative counter values.
    pub counters: HashMap<String, u64>,
    /// Last-recorded gauge values.
    pub gauges: HashMap<String, f64>,
}

/// Latency statistics for a single operation.
#[derive(Debug, Clone, Default, serde::Serialize)]
pub struct LatencyStats {
    pub count: u64,
    pub total_ms: f64,
    pub min_ms: f64,
    pub max_ms: f64,
    pub p50_ms: f64,
    pub p95_ms: f64,
    pub p99_ms: f64,
}

#[cfg(test)]
#[path = "tests/metrics_tests.rs"]
mod tests;