Struct dipstick::ObserveWhen

pub struct ObserveWhen<'a, T, F> { /* private fields */ }

When to observe a recurring task.

Implementations

impl<'a, T, F> ObserveWhen<'a, T, F>

where F: Fn(Instant) -> MetricValue + Send + Sync + 'static, T: InputScope + WithAttributes + Send + Sync,

pub fn on_flush(self) -> OnFlushCancel

Observe the metric’s value upon flushing the scope.

Examples found in repository

examples/observer.rs (line 26)

fn main() {
    let metrics = AtomicBucket::new().named("process");
    metrics.drain(Stream::write_to_stdout());
    metrics.flush_every(Duration::from_secs(3));

    let uptime = metrics.gauge("uptime");
    metrics.observe(uptime, |_| 6).on_flush();

    // record number of threads in pool every second
    let scheduled = metrics
        .observe(metrics.gauge("threads"), thread_count)
        .every(Duration::from_secs(1));

    // "heartbeat" metric
    let on_flush = metrics
        .observe(metrics.marker("heartbeat"), |_| 1)
        .on_flush();

    for _ in 0..1000 {
        std::thread::sleep(Duration::from_millis(40));
    }

    on_flush.cancel();
    scheduled.cancel();
}

pub fn every(self, period: Duration) -> CancelHandle

Observe the metric’s value periodically.

Examples found in repository

examples/observer.rs (line 31)

fn main() {
    let metrics = AtomicBucket::new().named("process");
    metrics.drain(Stream::write_to_stdout());
    metrics.flush_every(Duration::from_secs(3));

    let uptime = metrics.gauge("uptime");
    metrics.observe(uptime, |_| 6).on_flush();

    // record number of threads in pool every second
    let scheduled = metrics
        .observe(metrics.gauge("threads"), thread_count)
        .every(Duration::from_secs(1));

    // "heartbeat" metric
    let on_flush = metrics
        .observe(metrics.marker("heartbeat"), |_| 1)
        .on_flush();

    for _ in 0..1000 {
        std::thread::sleep(Duration::from_millis(40));
    }

    on_flush.cancel();
    scheduled.cancel();
}