Struct MetricsCollector 

pub struct MetricsCollector { /* private fields */ }

Metrics collector for buffering and batching metrics.

Implementations

impl MetricsCollector

pub fn new(config: MetricsConfig) -> Self

Create a new metrics collector.

pub async fn record(&self, metric: Metric)

Record a metric.

pub async fn increment_counter(&self, name: impl Into<String>, value: f64)

Record a counter increment.

pub async fn set_gauge(&self, name: impl Into<String>, value: f64)

Record a gauge value.

pub async fn flush(&self)

Flush the buffer.

pub async fn drain(&self) -> Vec<Metric>

Drain the buffer and return all metrics.

This is used by the flush loop to get metrics for persistence.

pub fn subscribe(&self) -> Receiver<Vec<Metric>>

Get the flush receiver for consuming batches.

pub fn count(&self) -> u64

Get collected metrics count.

pub async fn buffer_size(&self) -> usize

Get current buffer size.

pub async fn run(&self)

Run the flush loop.