jaeb 0.4.0

simple snapshot-driven event bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

#[cfg(feature = "metrics")]
use metrics::histogram;

#[cfg(feature = "metrics")]
pub(crate) struct TimerGuard {
    start: std::time::Instant,
    name: &'static str,
    event: &'static str,
    handler: Option<&'static str>,
}

#[cfg(feature = "metrics")]
impl TimerGuard {
    pub fn start(name: &'static str, event: &'static str, handler: Option<&'static str>) -> Self {
        Self {
            start: std::time::Instant::now(),
            name,
            event,
            handler,
        }
    }
}

#[cfg(feature = "metrics")]
impl Drop for TimerGuard {
    fn drop(&mut self) {
        let dur = self.start.elapsed();
        let histogram = if let Some(listener) = self.handler {
            histogram!(self.name, "event" => self.event, "handler" => listener)
        } else {
            histogram!(self.name, "event" => self.event)
        };
        histogram.record(dur.as_secs_f64());
    }
}