Struct SimpleRate 

pub struct SimpleRate { /* private fields */ }

A simple rate: the rate is incrementally calculated based on the elapsed time between the earliest reading and now.

An exception is made for the first window, which is considered of fixed size. This avoids the issue of an artificially high rate when the gap between readings is close to 0.

Translation notes

Composes a Rate instead of extending it.

Implementations

impl SimpleRate

pub fn new() -> Self

Create a SimpleRate over seconds backed by a WindowedSum.

pub fn window_size(&self, config: &MetricConfig, now: i64) -> i64

Compute the window size in milliseconds, overriding Rate::window_size: max(elapsed, config.timeWindowMs()).

Arguments

• config - the metric’s configuration
• now - the current POSIX time in milliseconds

Returns

The window size in milliseconds.

Trait Implementations

impl Debug for SimpleRate

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

Formats the value using the given formatter.

impl Default for SimpleRate

fn default() -> Self

Returns the “default value” for a type.

impl Display for SimpleRate

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

Java’s Rate.toString(), which SimpleRate inherits.

impl Measurable for SimpleRate

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.

impl Stat for SimpleRate

fn record(&self, config: &MetricConfig, value: f64, time_ms: i64)

Record the given value.