Struct influxdb_dispatcher::InfluxDbHandle

pub struct InfluxDbHandle<M> { /* private fields */ }

A handle to the InfluxDb metrics recorder. Aborts the submission task when dropped.

Implementations

impl<M> InfluxDbHandle<M>where
M: Send + 'static,

pub fn new<C>(consumer: C, push_interval: u64, buffer_size: usize) -> Selfwhere
C: MetricsConsumer<Metric = M> + Send + 'static,

Start the metrics task. This task will run indefinitely, but will be aborted when the handle is dropped.

pub fn submit(&self, metric: M)

Submit a metric. There is no strong guarantee that the metric will be recorded. It may actually be discarded if we’re struggling to dispatch all metrics.

Trait Implementations

impl<M: Debug> Debug for InfluxDbHandle<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M> Drop for InfluxDbHandle<M>

fn drop(&mut self)

Executes the destructor for this type.