Struct dipstick::AtomicBucket

pub struct AtomicBucket { /* fields omitted */ }

Central aggregation structure. Maintains a list of metrics for enumeration when used as source.

Methods

impl AtomicBucket

pub fn new() -> AtomicBucket

Build a new atomic bucket.

pub fn set_default_stats<F>(func: F) where     F: Fn(InputKind, MetricName, ScoreType) -> Option<(InputKind, MetricName, MetricValue)> + Send + Sync + 'static,

Set the default aggregated metrics statistics generator.

pub fn unset_default_stats()

Revert the default aggregated metrics statistics generator to the default stats_summary.

pub fn set_default_drain(     default_config: impl Output + Send + Sync + 'static )

Set the default bucket aggregated metrics flush output.

pub fn unset_default_drain()

Revert the default bucket aggregated metrics flush output.

pub fn set_stats<F>(&self, func: F) where     F: Fn(InputKind, MetricName, ScoreType) -> Option<(InputKind, MetricName, MetricValue)> + Send + Sync + 'static,

Set this bucket's statistics generator.

pub fn unset_stats<F>(&self)

Revert this bucket's statistics generator to the default stats.

pub fn set_drain(     &self,     new_drain: impl Output + Send + Sync + 'static )

Set this bucket's aggregated metrics flush output.

pub fn unset_drain(&self)

Revert this bucket's flush target to the default output.

pub fn flush_to(&self, publish_scope: &dyn OutputScope) -> Result<()>

Immediately flush the bucket's metrics to the specified scope and stats.

Trait Implementations

impl InputScope for AtomicBucket

fn new_metric(&self, name: MetricName, kind: InputKind) -> InputMetric

Lookup or create scores for the requested metric.

fn counter(&self, name: &str) -> Counter

Define a counter.

fn marker(&self, name: &str) -> Marker

Define a marker.

fn timer(&self, name: &str) -> Timer

Define a timer.

fn gauge(&self, name: &str) -> Gauge

Define a gauge.

fn level(&self, name: &str) -> Level

Define a level.

impl Flush for AtomicBucket

fn flush(&self) -> Result<()>

Collect and reset aggregated data. Publish statistics

impl<S: AsRef<str>> From<S> for AtomicBucket

fn from(name: S) -> AtomicBucket

Performs the conversion.

impl Clone for AtomicBucket

fn clone(&self) -> AtomicBucket

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AtomicBucket

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

Formats the value using the given formatter.