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
55
56

// Will create an exporter with a single metric that will randomize the value
// of the metric everytime the exporter is called.

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:9185";
    let addr: SocketAddr = addr_raw.parse().expect("can not parse listen addr");

    // Start exporter
    let exporter = prometheus_exporter::start(addr).expect("can not start exporter");

    // 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();

    std::thread::spawn(move || {
        loop {
            std::thread::sleep(std::time::Duration::from_millis(1000));

            // 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);
        }
    });

    loop {
        // Will block until a new request comes in.
        let _guard = exporter.wait_request();
        info!("Updating metrics");

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

        random.set(new_value);
    }
}