Struct mz_cluster_client::metrics::WallclockLagMetrics

pub struct WallclockLagMetrics {
    wallclock_lag_seconds_min: DeleteOnDropGauge<'static, AtomicF64, Vec<String>>,
    wallclock_lag_seconds_max: DeleteOnDropGauge<'static, AtomicF64, Vec<String>>,
    wallclock_lag_seconds_sum: DeleteOnDropCounter<'static, AtomicF64, Vec<String>>,
    wallclock_lag_seconds_count: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>,
    wallclock_lag_minmax: SlidingMinMax<f32>,
}

Metrics tracking frontier wallclock lag for a collection.

Fields

wallclock_lag_seconds_min: DeleteOnDropGauge<'static, AtomicF64, Vec<String>>

Gauge tracking minimum dataflow wallclock lag.

wallclock_lag_seconds_max: DeleteOnDropGauge<'static, AtomicF64, Vec<String>>

Gauge tracking maximum dataflow wallclock lag.

wallclock_lag_seconds_sum: DeleteOnDropCounter<'static, AtomicF64, Vec<String>>

Counter tracking the total sum of dataflow wallclock lag.

wallclock_lag_seconds_count: DeleteOnDropCounter<'static, AtomicU64, Vec<String>>

Counter tracking the total count of dataflow wallclock lag measurements.

wallclock_lag_minmax: SlidingMinMax<f32>

State maintaining minimum and maximum wallclock lag.

Implementations

impl WallclockLagMetrics

pub fn observe(&mut self, lag: Duration)

Observe a new wallclock lag measurement.

Trait Implementations

impl Debug for WallclockLagMetrics

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

Formats the value using the given formatter.