Struct EmbeddingDriftDetector 

pub struct EmbeddingDriftDetector {
    pub id: String,
    pub config: DetectorConfig,
    /* private fields */
}

Detects concept drift in a stream of high-dimensional embeddings.

Maintains a rolling window and a reference window; when the rolling window fills it is compared to the reference window using the configured DetectionMethod.

Fields

id: String

Detector identifier (used in emitted DriftSignal values).

config: DetectorConfig

Configuration.

Implementations

impl EmbeddingDriftDetector

pub fn new(config: DetectorConfig) -> Self

Creates a new detector with the given configuration.

pub fn with_id(id: impl Into<String>, config: DetectorConfig) -> Self

Creates a new detector with a custom string identifier.

pub fn add_sample( &mut self, embedding: Vec<f64>, timestamp: u64, ) -> Result<Option<DriftSignal>, DetectorError>

Adds one embedding to the rolling window.

Returns Ok(Some(signal)) when drift is detected, Ok(None) otherwise.

pub fn take_snapshot( &mut self, timestamp: u64, ) -> Result<DriftSnapshot, DetectorError>

Computes a snapshot of the current rolling window.

pub fn compare_snapshots( &self, reference: &DriftSnapshot, current: &DriftSnapshot, ) -> Result<DriftSignal, DetectorError>

Compares two snapshots using the configured DetectionMethod.

Returns a DriftSignal whose magnitude is 0.0 if no drift was detected, and positive otherwise.

pub fn reset_reference(&mut self) -> Result<(), DetectorError>

Copies the current rolling window into the reference window.

pub fn drift_history(&self) -> Vec<DriftSignal>

Returns the last 100 drift signals (oldest first).

pub fn stats(&self) -> DriftStats

Returns aggregate statistics for this detector.

pub fn window_len(&self) -> usize

Returns the number of samples in the rolling window.

pub fn reference_len(&self) -> usize

Returns the number of samples in the reference window.

pub fn embedding_dim(&self) -> Option<usize>

Returns the established embedding dimension (if any sample has been added).

pub fn random_f64(&mut self) -> f64

Draws a pseudo-random f64 from the internal PRNG.