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 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 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, 

Deprecated since 0.7.2:

Use stats()

Set this bucket's statistics generator.

pub fn 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(&self)

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

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

Deprecated since 0.7.2:

Use drain()

Set this bucket's aggregated metrics flush output.

pub fn 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 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.

impl Default for AtomicBucket

fn default() -> AtomicBucket

Returns the "default value" for a type.

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 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.