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::gauge::new.

Implementations

impl<F> ClosureMeasurable<F>

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

pub fn new(f: F) -> Self

Wraps a closure as a measurable.

Arguments

• f - the closure computing the value from the config and the time in milliseconds

Trait Implementations

impl<F> Debug for ClosureMeasurable<F>

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

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

Formats the value using the given formatter.

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 a double.

fn type_name(&self) -> Option<&'static str>

Returns the provider’s type name, as KafkaMetric’s Display reports it, or None for a provider that is a closure.