Struct EmbeddingDriftMonitor 

pub struct EmbeddingDriftMonitor {
    pub baseline: Option<BaselineStats>,
    pub recent: Vec<Vec<f32>>,
    pub config: DriftMonitorConfig,
    pub stats: DriftMonitorStats,
    pub update_counter: usize,
}

Monitors concept drift in embedding distributions.

Maintains a sliding window of recent vectors, periodically recomputes a baseline, and classifies each new vector against the baseline using normalised per-dimension deviation.

Fields

baseline: Option<BaselineStats>

Current baseline statistics, if enough samples have been seen.

recent: Vec<Vec<f32>>

Sliding window of recent vectors.

config: DriftMonitorConfig

Monitor configuration.

stats: DriftMonitorStats

Cumulative statistics.

update_counter: usize

Number of vectors added since the last baseline update.

Implementations

impl EmbeddingDriftMonitor

pub fn new(config: DriftMonitorConfig) -> Self

Create a new monitor with the given configuration.

pub fn add_vector(&mut self, vec: Vec<f32>) -> DriftSignal

Add a vector to the monitor and return a DriftSignal.

Steps:

1. Push vec into the sliding window, evicting the oldest entry when recent.len() > window_size.
2. Increment update_counter; if update_counter >= baseline_update_interval and enough samples exist, recompute the baseline.
3. If no baseline is available, return DriftSignal::InsufficientData.
4. Otherwise, compute the mean absolute normalised deviation and classify.

pub fn baseline(&self) -> Option<&BaselineStats>

Return a reference to the current baseline statistics, if available.

pub fn stats(&self) -> &DriftMonitorStats

Return a reference to the cumulative statistics.

pub fn reset_baseline(&mut self)

Clear the baseline, recent window, and reset counters.