influxive 0.0.5

High-level Rust integration of opentelemetry metrics and InfluxDB
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

use super::*;
use std::io::BufRead;

#[tokio::test(flavor = "multi_thread")]
async fn file_meter_provider_one_metric_one_value() {
    let tmp = tempfile::tempdir().unwrap();
    let test_path = tmp
        .path()
        .join(std::path::PathBuf::from("unit_test_metrics.influx"));

    // create our meter provider
    let meter_provider = influxive_file_meter_provider(
        InfluxiveWriterConfig::create_with_influx_file(test_path.clone()),
        InfluxiveMeterProviderConfig::default(),
    );

    // register our meter provider
    opentelemetry_api::global::set_meter_provider(meter_provider);

    // create a metric
    let m = opentelemetry_api::global::meter("my.meter")
        .f64_histogram("my.metric")
        .init();

    // make a recording
    m.record(3.14, &[]);

    // Wait for the metric to be written
    tokio::time::sleep(std::time::Duration::from_millis(200)).await;

    // Check file content for metric
    let file = std::fs::File::open(&test_path).unwrap();
    let reader = std::io::BufReader::new(file);
    let res = reader.lines().next().transpose().unwrap();
    assert!(res.is_some());
    let line = res.unwrap();
    let split = line.split(' ').collect::<Vec<&str>>();
    assert_eq!(split[0], "my.metric");
    assert!(split[1].contains(&"3.14"));
}