driftwatch 0.1.0

Data & model drift detection for Rust — PSI, KL/JS divergence, KS and chi-square tests, live windowing, and pluggable alerting.
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

//! `tracing`-based alerter (feature `alerting-log`).

use super::{Alerter, DriftAlertEvent};

/// An [`Alerter`] that emits a structured `tracing` event on drift detection.
///
/// It deliberately reuses whatever `tracing` subscriber your application already
/// installs (the same setup the guide's Deployment/Monitoring chapters
/// establish), rather than introducing a separate logging story. The event is
/// emitted at `WARN` level on the `driftwatch` target with the drifted-feature
/// count and fraction as fields.
#[derive(Clone, Copy, Debug, Default)]
pub struct LogAlerter;

impl LogAlerter {
    /// Create a new `LogAlerter`.
    pub fn new() -> Self {
        Self
    }
}

impl Alerter for LogAlerter {
    fn alert(&self, event: &DriftAlertEvent) {
        tracing::warn!(
            target: "driftwatch",
            dataset_drifted = event.dataset_drifted,
            drifted_fraction = event.drifted_fraction,
            drifted_features = event.features.len(),
            timestamp_secs = event.timestamp_secs,
            "data drift detected"
        );
        for f in &event.features {
            tracing::warn!(
                target: "driftwatch",
                feature = %f.feature,
                metric = %f.metric,
                score = f.score,
                threshold = f.threshold,
                "feature drift"
            );
        }
    }
}