Function dipstick::aggregate
[−]
[src]
pub fn aggregate<E, M>(stat_fn: E, to_chain: Chain<M>) -> Chain<Aggregate> where
E: Fn(Kind, &str, ScoreType) -> Option<(Kind, Vec<&str>, Value)> + Send + Sync + 'static,
M: Clone + Send + Sync + Debug + 'static,
Aggregate metrics in memory. Depending on the type of metric, count, sum, minimum and maximum of values will be tracked. Needs to be connected to a publish to be useful.
use dipstick::*; let sink = aggregate(4, summary, to_stdout()); let metrics = global_metrics(sink); metrics.marker("my_event").mark(); metrics.marker("my_event").mark();