Struct dipstick::MetricQueue

pub struct MetricQueue<M, S> { /* fields omitted */ }

A metric command-queue using a sync channel. Each client thread gets it's own scope and sender. Writes are dispatched by a single receiving thread.

Trait Implementations

impl<M: Debug, S: Debug> Debug for MetricQueue<M, S>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<M, S> Sink<Arc<M>> for MetricQueue<M, S> where
    S: Sink<M>,
    M: 'static + Clone + Send + Sync, 

fn new_metric(&self, kind: Kind, name: &str, sampling: Rate) -> Arc<M>

Define a new metric instrument of the requested kind, with the specified name and sample rate.

fn new_scope(&self, auto_flush: bool) -> ScopeFn<Arc<M>>

Returns a callback function to send scope commands. Writes can be performed by passing Some((&Metric, Value)) Flushes can be performed by passing None