triglav 0.1.0

High-performance multi-path networking tool with intelligent uplink management
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

//! Quality metrics, predictive analytics, and Prometheus export.
//!
//! This module provides:
//! - Real-time quality measurement
//! - Historical data tracking
//! - Predictive quality estimation
//! - Anomaly detection
//! - Prometheus metrics export
//! - HTTP health endpoints

mod quality;
mod predictor;
#[cfg(feature = "metrics")]
mod prometheus_export;
#[cfg(feature = "metrics")]
mod http_server;

pub use quality::QualityMetrics;
pub use predictor::{QualityPredictor, Prediction};
#[cfg(feature = "metrics")]
pub use prometheus_export::*;
#[cfg(feature = "metrics")]
pub use http_server::*;

use std::time::Duration;

use serde::{Deserialize, Serialize};


/// Metrics configuration.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct MetricsConfig {
    /// Sample window for averaging.
    #[serde(default = "default_sample_window", with = "humantime_serde")]
    pub sample_window: Duration,

    /// History retention period.
    #[serde(default = "default_history_retention", with = "humantime_serde")]
    pub history_retention: Duration,

    /// Anomaly detection threshold (standard deviations).
    #[serde(default = "default_anomaly_threshold")]
    pub anomaly_threshold: f64,

    /// Enable predictive analytics.
    #[serde(default = "default_prediction")]
    pub prediction_enabled: bool,

    /// Prediction horizon.
    #[serde(default = "default_prediction_horizon", with = "humantime_serde")]
    pub prediction_horizon: Duration,

    /// Enable Prometheus metrics export.
    #[serde(default = "default_prometheus")]
    pub prometheus_enabled: bool,

    /// HTTP server bind address for metrics/health.
    #[serde(default = "default_http_bind")]
    pub http_bind: String,

    /// Enable per-user metrics.
    #[serde(default)]
    pub per_user_metrics: bool,
}

fn default_sample_window() -> Duration { Duration::from_secs(10) }
fn default_history_retention() -> Duration { Duration::from_secs(3600) }
fn default_anomaly_threshold() -> f64 { 3.0 }
fn default_prediction() -> bool { true }
fn default_prediction_horizon() -> Duration { Duration::from_secs(60) }
fn default_prometheus() -> bool { true }
fn default_http_bind() -> String { "0.0.0.0:9090".to_string() }

impl Default for MetricsConfig {
    fn default() -> Self {
        Self {
            sample_window: default_sample_window(),
            history_retention: default_history_retention(),
            anomaly_threshold: default_anomaly_threshold(),
            prediction_enabled: default_prediction(),
            prediction_horizon: default_prediction_horizon(),
            prometheus_enabled: default_prometheus(),
            http_bind: default_http_bind(),
            per_user_metrics: false,
        }
    }
}