prometheus_exporter 0.8.5

Helper libary to export prometheus metrics using tiny-http.
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

// Will create an exporter with a single metric that will randomize the value
// of the metric everytime the exporter duration times out.

use env_logger::{
    Builder,
    Env,
};
use log::info;
use prometheus_exporter::prometheus::register_gauge;
use rand::Rng;
use std::net::SocketAddr;

fn main() {
    // Setup logger with default level info so we can see the messages from
    // prometheus_exporter.
    Builder::from_env(Env::default().default_filter_or("info")).init();

    // Parse address used to bind exporter to.
    let addr_raw = "0.0.0.0:9186";
    let addr: SocketAddr = addr_raw.parse().expect("can not parse listen addr");

    // Start exporter and update metrics every five seconds.
    let exporter = prometheus_exporter::start(addr).expect("can not start exporter");
    let duration = std::time::Duration::from_millis(1000);

    // Create metric
    let random = register_gauge!("run_and_repeat_random", "will set a random value")
        .expect("can not create gauge random_value_metric");

    let mut rng = rand::thread_rng();

    loop {
        {
            // Will block until duration is elapsed.
            let _guard = exporter.wait_duration(duration);

            info!("Updating metrics");

            // Update metric with random value.
            let new_value = rng.gen();
            info!("New random value: {}", new_value);

            random.set(new_value);
        }

        // Get metrics from exporter
        let body = reqwest::blocking::get(&format!("http://{}/metrics", addr_raw))
            .expect("can not get metrics from exporter")
            .text()
            .expect("can not body text from request");

        info!("Exporter metrics:\n{}", body);
    }
}