Struct ClosureMeasurable 

pub struct ClosureMeasurable<F>(/* private fields */)
where
    F: Fn(&MetricConfig, i64) -> f64 + Send + Sync;

A Measurable backed by a closure, mirroring Java’s functional-interface usage of Measurable (e.g. (config, now) -> TimeUnit.SECONDS.convert(...) in KafkaConsumerMetrics / HeartbeatMetricsManager). The symmetric counterpart of crate::common::metrics::ClosureGauge.

Implementations

impl<F> ClosureMeasurable<F>

where F: Fn(&MetricConfig, i64) -> f64 + Send + Sync,

pub fn new(f: F) -> Self

Wrap a closure as a measurable.

Trait Implementations

impl<F> Measurable for ClosureMeasurable<F>

where F: Fn(&MetricConfig, i64) -> f64 + Send + Sync,

fn measure(&self, config: &MetricConfig, now: i64) -> f64

Measure this quantity and return the result as an f64.