Struct MetricsCollector 

pub struct MetricsCollector { /* private fields */ }

Implementations

impl MetricsCollector

pub fn new() -> (MetricsCollector, Receiver<MetricsSnapshot>)

pub fn update(&self, f: impl FnOnce(&mut MetricsSnapshot))

pub fn set_context_max_tokens(&self, max_tokens: u64)

Publish the runtime-resolved context window limit.

Call after the provider pool is constructed (builder) and on every successful /provider switch so the TUI context gauge reflects the active provider’s window.

Examples

use zeph_core::metrics::MetricsCollector;

let (collector, rx) = MetricsCollector::new();
collector.set_context_max_tokens(128_000);
assert_eq!(rx.borrow().context_max_tokens, 128_000);

pub fn record_compaction(&self, before: u64, after: u64, at_ms: u64)

Record the outcome of the most recent compaction event.

Sets all three compaction_last_* fields atomically. at_ms is the Unix epoch in milliseconds — obtain via SystemTime::UNIX_EPOCH.elapsed().unwrap_or_default().as_millis().

Examples

use zeph_core::metrics::MetricsCollector;

let (collector, rx) = MetricsCollector::new();
collector.record_compaction(50_000, 12_000, 1_700_000_000_000);
let snap = rx.borrow();
assert_eq!(snap.compaction_last_before, 50_000);
assert_eq!(snap.compaction_last_after, 12_000);
assert_eq!(snap.compaction_last_at_ms, 1_700_000_000_000);

pub fn sender(&self) -> Sender<MetricsSnapshot>

Returns a clone of the underlying watch::Sender.

Use this to pass the sender to code that requires a raw watch::Sender<MetricsSnapshot> while the MetricsCollector is also shared (e.g., passed to a MetricsBridge layer).