Struct MetricCollector

pub struct MetricCollector { /* private fields */ }

A metric collector that uses lock-free ring buffers

Implementations

impl MetricCollector

pub fn new(name: String, config: MonitoringConfig) -> Self

Create a new metric collector

pub fn with_channel( name: String, config: MonitoringConfig, sender: Sender<Vec<Metric>>, ) -> Self

Create a collector connected to a processing channel

pub fn record(&self, metric: Metric)

Record a metric with minimal overhead

pub fn start_flusher(&self) -> Result<JoinHandle<()>>

Start the background flushing thread

pub fn flush(&self) -> Vec<Metric>

Manually flush metrics from the buffer

pub fn stats(&self) -> CollectorStats

Get collector statistics

pub fn name(&self) -> &str

Get the collector name

pub fn buffer_size(&self) -> usize

Get the current buffer size