rs-zero 0.2.6

Rust-first microservice framework inspired by go-zero engineering practices
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

use std::{collections::BTreeMap, fmt::Write};

use super::{DurationMetricValue, escape_label, write_duration_metric};

/// Low-cardinality labels recorded for each HTTP request.
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord)]
pub struct HttpMetricLabels {
    /// HTTP method.
    pub method: String,
    /// Route pattern or explicit route name. Raw request paths should not be used.
    pub route: String,
    /// HTTP status code.
    pub status: u16,
}

impl HttpMetricLabels {
    /// Creates a label set for one HTTP request.
    pub fn new(method: impl Into<String>, route: impl Into<String>, status: u16) -> Self {
        Self {
            method: method.into(),
            route: route.into(),
            status,
        }
    }
}

pub(crate) fn render(
    output: &mut String,
    metrics: &BTreeMap<HttpMetricLabels, DurationMetricValue>,
    in_flight: i64,
) {
    output.push_str("# HELP rs_zero_http_requests_total Total number of HTTP requests.\n");
    output.push_str("# TYPE rs_zero_http_requests_total counter\n");
    for (labels, value) in metrics {
        write!(output, "rs_zero_http_requests_total{{").ok();
        write_labels(output, labels, None);
        writeln!(output, "}} {}", value.count).ok();
    }

    output.push_str("# HELP rs_zero_http_request_duration_seconds HTTP request duration.\n");
    output.push_str("# TYPE rs_zero_http_request_duration_seconds histogram\n");
    for (labels, value) in metrics {
        write_duration_metric(
            output,
            "rs_zero_http_request_duration_seconds",
            labels,
            value,
            write_labels,
        );
    }

    output.push_str("# HELP rs_zero_http_requests_in_flight Current in-flight HTTP requests.\n");
    output.push_str("# TYPE rs_zero_http_requests_in_flight gauge\n");
    writeln!(output, "rs_zero_http_requests_in_flight {in_flight}").ok();
}

fn write_labels(output: &mut String, labels: &HttpMetricLabels, le: Option<&str>) {
    write!(
        output,
        "method=\"{}\",route=\"{}\",status=\"{}\"",
        escape_label(&labels.method),
        escape_label(&labels.route),
        labels.status
    )
    .ok();
    if let Some(le) = le {
        write!(output, ",le=\"{}\"", escape_label(le)).ok();
    }
}