limon 0.1.1

limon-sdk library
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

//! A module for managing metrics and collecting system metrics.

use std::{
  sync::{Arc, Mutex},
  time::Duration,
};

use opentelemetry::{KeyValue, Value, global};
use opentelemetry_otlp::WithExportConfig;
use opentelemetry_sdk::{
  Resource,
  metrics::{PeriodicReader, SdkMeterProvider},
};
use sysinfo::RefreshKind;

/// Configuration for metrics integration.
#[derive(Clone)]
pub struct MetricsConfig {
  /// The endpoint URL where metrics are sent.
  pub endpoint: String,

  /// The interval at which metrics are collected and sent.
  pub interval: Duration,
}

impl Default for MetricsConfig {
  fn default() -> Self {
    Self {
      endpoint: String::from("https://limonen.click:5130/v1/metrics"),
      interval: Duration::from_secs(30),
    }
  }
}

pub(crate) struct MetricsSdk;

impl MetricsSdk {
  pub fn init(config: MetricsConfig) {
    let exporter = opentelemetry_otlp::MetricExporter::builder()
      .with_http()
      .with_endpoint(config.endpoint)
      .build()
      .expect("opentelemetry exporter failed");

    let reader = PeriodicReader::builder(exporter)
      .with_interval(config.interval)
      .build();

    let provider = SdkMeterProvider::builder()
      .with_resource(
        Resource::builder()
          .with_service_name(env!("CARGO_PKG_NAME"))
          .build(),
      )
      .with_reader(reader)
      .build();

    global::set_meter_provider(provider);

    #[cfg(feature = "sysinfo")]
    Self::setup_system_metrics()
  }

  #[cfg(feature = "sysinfo")]
  fn setup_system_metrics() {
    let meter = global::meter("system.runtime");
    let system = Arc::new(Mutex::new(sysinfo::System::new_with_specifics(
      RefreshKind::everything().without_processes(),
    )));

    meter
      .u64_observable_gauge("system.memory.usage")
      .with_description("Amount of used RAM in KB")
      .with_callback({
        let system = Arc::clone(&system);

        move |observer| {
          let mut s = system.lock().unwrap();

          s.refresh_memory();

          observer.observe(s.used_memory(), &[]);
        }
      })
      .build();

    meter
      .u64_observable_gauge("system.memory.total")
      .with_description("Amount of total RAM in KB")
      .with_callback({
        let system = Arc::clone(&system);

        move |observer| {
          let mut s = system.lock().unwrap();

          s.refresh_memory();

          observer.observe(s.total_memory(), &[]);
        }
      })
      .build();

    meter
      .f64_observable_gauge("system.cpu.usage")
      .with_description("CPU load in percentage across all cores")
      .with_callback({
        let system = Arc::clone(&system);

        move |observer| {
          let mut s = system.lock().unwrap();

          s.refresh_cpu_usage();

          for (i, cpu) in s.cpus().iter().enumerate() {
            observer.observe(
              cpu.cpu_usage() as f64,
              &[KeyValue::new("core", Value::I64(i as i64))],
            );
          }
        }
      })
      .build();
  }
}