Struct StatBatcher 

pub struct StatBatcher { /* private fields */ }

Accumulates stats locally so that semi-trusted nodes (bridges, exits) can ship them to the broker in periodic batches: counters with identical name+tags are summed, gauges keep the last value, and timers are kept as individual events.

Implementations

impl StatBatcher

pub fn new() -> Self

pub fn push(&self, event: StatEvent)

pub fn counter(&self, name: &str, tags: &[(&str, &str)], value: f64)

pub fn gauge(&self, name: &str, tags: &[(&str, &str)], value: f64)

pub fn timer_ms(&self, name: &str, tags: &[(&str, &str)], value: f64)

pub fn drain(&self) -> Vec<StatEvent>

Takes all accumulated events, leaving the batcher empty.

Trait Implementations

impl Default for StatBatcher

fn default() -> StatBatcher

Returns the “default value” for a type.