Struct dipstick::Publisher

pub struct Publisher<E, M> { /* fields omitted */ }

Define and write metrics from aggregated scores to the target channel If this is called repeatedly it can be a good idea to use the metric cache to prevent new metrics from being created every time.

Methods

impl<E, M> Publisher<E, M> where
    E: Fn(Kind, &str, ScoreType) -> Option<(Kind, Vec<&str>, Value)> + Send + Sync + 'static,
    M: Clone + Send + Sync + 'static, 

pub fn new(stat_fn: E, target_chain: Chain<M>) -> Self

Define a new metrics publishing strategy, from a transformation function and a target metric chain.

Trait Implementations

impl<E, M> Debug for Publisher<E, M> where
    M: Debug, 

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

Formats the value using the given formatter.

impl<E: Clone, M: Clone> Clone for Publisher<E, M>

fn clone(&self) -> Publisher<E, M>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E, M> Publish for Publisher<E, M> where
    M: Clone + Send + Sync + Debug + 'static,
    E: Fn(Kind, &str, ScoreType) -> Option<(Kind, Vec<&str>, Value)> + Send + Sync + 'static, 

fn publish(&self, snapshot: Vec<ScoreSnapshot>)

Publish the provided metrics data downstream.