Struct MetricsExporter 

pub struct MetricsExporter { /* private fields */ }

Metrics exporter for workflow analytics

Implementations

impl MetricsExporter

pub fn new(workflow_name: impl Into<String>) -> Self

Create a new metrics exporter

pub fn with_label( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add a label/tag to all exported metrics

pub fn with_namespace(self, namespace: impl Into<String>) -> Self

Set the namespace for metrics

pub fn export_prometheus( &self, analytics: &WorkflowAnalytics, ) -> Result<String, MetricsError>

Export analytics to Prometheus text format

pub fn export_opentelemetry( &self, analytics: &WorkflowAnalytics, ) -> Result<Value, MetricsError>

Export analytics to OpenTelemetry JSON format

pub fn export_influxdb( &self, analytics: &WorkflowAnalytics, ) -> Result<String, MetricsError>

Export analytics to InfluxDB line protocol

pub fn export_json( &self, analytics: &WorkflowAnalytics, ) -> Result<Value, MetricsError>

Export analytics to generic JSON format

pub fn export( &self, analytics: &WorkflowAnalytics, format: ExportFormat, ) -> Result<String, MetricsError>

Export analytics in the specified format

Trait Implementations

impl Clone for MetricsExporter

fn clone(&self) -> MetricsExporter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsExporter

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

Formats the value using the given formatter.