Struct ControllerMetrics

pub struct ControllerMetrics {
    dataflow_wallclock_lag_seconds: GaugeVec,
    dataflow_wallclock_lag_seconds_sum: CounterVec,
    dataflow_wallclock_lag_seconds_count: IntCounterVec,
}

Controller metrics.

Fields

dataflow_wallclock_lag_seconds: GaugeVec

dataflow_wallclock_lag_seconds_sum: CounterVec

dataflow_wallclock_lag_seconds_count: IntCounterVec

Implementations

impl ControllerMetrics

pub fn new(metrics_registry: &MetricsRegistry) -> Self

Create a metrics instance registered into the given registry.

pub fn wallclock_lag_metrics( &self, collection_id: String, instance_id: Option<String>, replica_id: Option<String>, ) -> WallclockLagMetrics

Return an object that tracks wallclock lag metrics for the given collection on the given cluster and replica.

Trait Implementations

impl Clone for ControllerMetrics

fn clone(&self) -> ControllerMetrics

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ControllerMetrics

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

Formats the value using the given formatter.