oxigdal-observability 0.1.7

OpenTelemetry-based observability, monitoring, and alerting for OxiGDAL
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

//! StatsD exporter.

use super::{Metric, MetricExporter, MetricValue};
use crate::error::Result;

/// StatsD exporter.
pub struct StatsdExporter {
    #[allow(dead_code)]
    address: String,
}

impl StatsdExporter {
    /// Create a new StatsD exporter.
    pub fn new(address: String) -> Self {
        Self { address }
    }
}

impl MetricExporter for StatsdExporter {
    fn export(&self, metrics: &[Metric]) -> Result<()> {
        for metric in metrics {
            let _message = match &metric.value {
                MetricValue::Counter(value) => format!("{}:{}|c", metric.name, value),
                MetricValue::Gauge(value) => format!("{}:{}|g", metric.name, value),
                MetricValue::Histogram(values) => {
                    let avg = if values.count > 0 {
                        values.sum / values.count as f64
                    } else {
                        0.0
                    };
                    format!("{}:{}|h", metric.name, avg)
                }
                MetricValue::Summary(summary) => {
                    let avg = if summary.count > 0 {
                        summary.sum / summary.count as f64
                    } else {
                        0.0
                    };
                    format!("{}:{}|ms", metric.name, avg)
                }
                MetricValue::Distribution(dist) => {
                    format!("{}:{}|d", metric.name, dist.mean)
                }
            };

            // In production, send via UDP to StatsD
        }

        Ok(())
    }

    fn flush(&self) -> Result<()> {
        Ok(())
    }

    fn name(&self) -> &str {
        "statsd"
    }
}