Function dipstick::aggregate

pub fn aggregate<E, M>(
    capacity: usize, 
    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();