autometrics 3.0.0

Easily add metrics to your code that actually help you spot and debug issues in production. Built on Prometheus and OpenTelemetry.
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

#![cfg(prometheus_exporter)]
use autometrics::{autometrics, objectives::*, prometheus_exporter};

#[test]
fn success_rate() {
    prometheus_exporter::try_init().ok();

    const OBJECTIVE: Objective = Objective::new("test").success_rate(ObjectivePercentile::P99);

    #[autometrics(objective = OBJECTIVE)]
    fn success_rate_fn() -> &'static str {
        "Hello world!"
    }

    success_rate_fn();
    success_rate_fn();

    let metrics = prometheus_exporter::encode_to_string().unwrap();
    assert!(metrics
        .lines()
        .any(|line| line.starts_with("function_calls_total{")

            && line.contains(r#"function="success_rate_fn""#)
            && line.contains(r#"objective_name="test""#)
            && line.contains(r#"objective_percentile="99""#)
            && line.ends_with("} 2")));
}

#[cfg(prometheus_exporter)]
#[test]
fn latency() {
    prometheus_exporter::try_init().ok();

    const OBJECTIVE: Objective =
        Objective::new("test").latency(ObjectiveLatency::Ms100, ObjectivePercentile::P99_9);

    #[autometrics(objective = OBJECTIVE)]
    fn latency_fn() -> &'static str {
        "Hello world!"
    }

    latency_fn();
    latency_fn();

    let metrics = prometheus_exporter::encode_to_string().unwrap();
    assert!(metrics.lines().any(|line| {
        line.starts_with("function_calls_duration_seconds_bucket{")
            && line.contains(r#"function="latency_fn""#)
            && line.contains(r#"objective_latency_threshold="0.1""#)
            && line.contains(r#"objective_name="test""#)
            && line.contains(r#"objective_percentile="99.9""#)
            && line.ends_with("} 2")
    }));
}

#[cfg(prometheus_exporter)]
#[test]
fn combined_objective() {
    prometheus_exporter::try_init().ok();

    const OBJECTIVE: Objective = Objective::new("test")
        .success_rate(ObjectivePercentile::P99)
        .latency(ObjectiveLatency::Ms100, ObjectivePercentile::P99_9);

    #[autometrics(objective = OBJECTIVE)]
    fn combined_objective_fn() -> &'static str {
        "Hello world!"
    }

    combined_objective_fn();
    combined_objective_fn();

    let metrics = prometheus_exporter::encode_to_string().unwrap();
    assert!(metrics.lines().any(|line| {
        line.starts_with("function_calls_total{")
            && line.contains(r#"function="combined_objective_fn""#)
            && line.contains(r#"objective_name="test""#)
            && line.contains(r#"objective_percentile="99""#)
            && line.ends_with("} 2")
    }));
    assert!(metrics.lines().any(|line| {
        line.starts_with("function_calls_duration_seconds_bucket{")
            && line.contains(r#"function="combined_objective_fn""#)
            && line.contains(r#"objective_latency_threshold="0.1""#)
            && line.contains(r#"objective_name="test""#)
            && line.contains(r#"objective_percentile="99.9""#)
            && line.ends_with("} 2")
    }));
}