Struct MetricsFileSink 

pub struct MetricsFileSink { /* private fields */ }

Writer for one metrics output file.

JSONL output appends one object per event. Prometheus output atomically replaces the file with the latest encoded snapshot on each write.

Implementations

impl MetricsFileSink

pub fn new(path: impl Into<PathBuf>, format: MetricsFileFormat) -> Result<Self>

Create a sink with the default Prometheus metric prefix.

pub fn with_prefix( path: impl Into<PathBuf>, format: MetricsFileFormat, metric_prefix: impl Into<String>, ) -> Result<Self>

Create a sink with a custom Prometheus metric prefix.

pub fn with_prefix_and_labels<I, K, V>( path: impl Into<PathBuf>, format: MetricsFileFormat, metric_prefix: impl Into<String>, labels: I, ) -> Result<Self>

where I: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<String>,

Create a sink with a custom Prometheus metric prefix and labels.

Labels are applied only to Prometheus text exposition output. JSONL output carries structured metric fields and its own schema version.

pub fn path(&self) -> &Path

Return the output path this sink writes.

pub fn format(&self) -> MetricsFileFormat

Return the configured output format.

pub fn write_event(&self, event: &MetricEvent) -> Result<()>

Write one metrics stream event.

pub fn write_interval(&self, metrics: &Metrics) -> Result<()>

Write one immediate interval sample.

pub fn write_window(&self, metrics: &WindowMetrics) -> Result<()>

Write one aggregated window summary.

Trait Implementations

impl Clone for MetricsFileSink

fn clone(&self) -> MetricsFileSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MetricsFileSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.