epimetheus 0.8.0

An easy-to-use prometheus-compatible metrics framework
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

use epimetheus::*;
use std::thread;
use std::time::*;

fn main() {
    std::env::set_var("RUST_LOG", "info");
    tracing_subscriber::fmt::init();
    epimetheus::spawn_http_server();
    thread::spawn(|| send_metrics_test());
    thread::spawn(|| send_metrics_test());
    thread::spawn(|| send_metrics_test());
    thread::spawn(|| bench_metrics());
    thread::spawn(|| bench_metrics_labeled());
    thread::spawn(|| bench_metrics_once());
    thread::spawn(|| bench_metrics_once_labelled());
    thread::sleep(Duration::from_secs(99999));
}

fn send_metrics_test() {
    loop {
        metric!(foobar).add(2.5);
        thread::sleep(Duration::from_secs(1));
    }
}

fn bench_metrics_labeled() {
    loop {
        let t1 = Instant::now();
        for _ in 0..1000 {
            let result = "failed";
            metric!(barqux{user=1, result=result}).add(2.5);
        }
        let d = t1.elapsed();
        metric!(bench_plain_seconds_sum).add(d.as_secs_f64());
        metric!(bench_plain_seconds_count).add(1000.0);
        println!("label:           {:?}", d);
        thread::sleep(Duration::from_millis(1001));
    }
}
fn bench_metrics() {
    loop {
        let t1 = Instant::now();
        for _ in 0..1000 {
            metric!(barqux).add(2.5);
        }
        let d = t1.elapsed();
        metric!(bench_labelled_seconds_sum).add(d.as_secs_f64());
        metric!(bench_labelled_seconds_count).add(1000.0);
        println!("plain: {:?}", d);
        thread::sleep(Duration::from_secs(1));
    }
}
fn bench_metrics_once() {
    loop {
        metric!(barqux).add(2.5);
        let t1 = Instant::now();
        metric!(barqux).add(2.5);
        let d = t1.elapsed();
        println!("once:                               {:?}", d);
        thread::sleep(Duration::from_millis(999));
    }
}
fn bench_metrics_once_labelled() {
    loop {
        metric!(barqux{foo=1}).add(2.5);
        let t1 = Instant::now();
        metric!(barqux{foo=1}).add(2.5);
        let d = t1.elapsed();
        println!("once:                                            {:?}", d);
        thread::sleep(Duration::from_millis(998));
    }
}