Struct dipstick::MultiInputScope

pub struct MultiInputScope { /* private fields */ }

Dispatch metric values to a list of scopes.

Implementations

impl MultiInputScope

pub fn new() -> Self

Create a new multi scope dispatcher with no scopes.

Examples found in repository

examples/clopwizard.rs (line 24)

fn main() {
    let one_minute = AtomicBucket::new();
    one_minute.flush_every(Duration::from_secs(60));

    let five_minutes = AtomicBucket::new();
    five_minutes.flush_every(Duration::from_secs(300));

    let fifteen_minutes = AtomicBucket::new();
    fifteen_minutes.flush_every(Duration::from_secs(900));

    let all_buckets = MultiInputScope::new()
        .add_target(one_minute)
        .add_target(five_minutes)
        .add_target(fifteen_minutes)
        .named("machine_name");

    // send application metrics to aggregator
    Proxy::default().target(all_buckets);
    AtomicBucket::default_drain(Stream::write_to_stdout());
    AtomicBucket::default_stats(stats_all);

    loop {
        COUNTER.count(17);
        sleep(Duration::from_secs(3));
    }
}

pub fn add_target<IN: InputScope + Send + Sync + 'static>(
    &self,
    scope: IN
) -> Self

Add a target to the dispatch list. Returns a clone of the original object.

Examples found in repository

examples/clopwizard.rs (line 25)

fn main() {
    let one_minute = AtomicBucket::new();
    one_minute.flush_every(Duration::from_secs(60));

    let five_minutes = AtomicBucket::new();
    five_minutes.flush_every(Duration::from_secs(300));

    let fifteen_minutes = AtomicBucket::new();
    fifteen_minutes.flush_every(Duration::from_secs(900));

    let all_buckets = MultiInputScope::new()
        .add_target(one_minute)
        .add_target(five_minutes)
        .add_target(fifteen_minutes)
        .named("machine_name");

    // send application metrics to aggregator
    Proxy::default().target(all_buckets);
    AtomicBucket::default_drain(Stream::write_to_stdout());
    AtomicBucket::default_stats(stats_all);

    loop {
        COUNTER.count(17);
        sleep(Duration::from_secs(3));
    }
}

Trait Implementations

impl Clone for MultiInputScope

fn clone(&self) -> MultiInputScope

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for MultiInputScope

fn default() -> MultiInputScope

Returns the “default value” for a type.

impl Flush for MultiInputScope

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

Flush does nothing by default.

impl InputScope for MultiInputScope

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

Define a generic metric of the specified type. It is preferable to use counter() / marker() / timer() / gauge() methods.

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 WithAttributes for MultiInputScope

fn get_attributes(&self) -> &Attributes

Return attributes of component.

fn mut_attributes(&mut self) -> &mut Attributes

Return attributes of component for mutation.

fn with_attributes<F: Fn(&mut Attributes)>(&self, edit: F) -> Self

Clone the component and mutate its attributes at once.