Struct MetaDriftDetector 

pub struct MetaDriftDetector { /* private fields */ }

CUSUM drift detector.

Feed anomaly scores through Self::observe one by one; the detector returns a DriftVerdict every time. Reset the accumulators via Self::reset once the caller has acted on a drift event; reset the whole state (including the reference EMA) via Self::reset_stats after a config change.

Implementations

impl MetaDriftDetector

pub fn new(config: CusumConfig) -> RcfResult<Self>

Build a detector with the supplied config.

Errors

Forwards CusumConfig::validate and EmaStats::new errors.

pub fn with_metrics_sink(self, sink: Arc<dyn MetricsSink>) -> Self

Install a crate::MetricsSink — emits rcf_drift_s_high / rcf_drift_s_low histograms per call and increments rcf_drift_fires_total on fire verdicts.

pub fn metrics_sink(&self) -> &Arc<dyn MetricsSink>

Read-only handle to the installed sink.

pub fn with_defaults() -> RcfResult<Self>

Default-configured detector.

Errors

Same as Self::new.

pub fn config(&self) -> &CusumConfig

Read-only CUSUM config.

pub fn stats(&self) -> &EmaStats

Running EMA of the score stream.

pub fn s_high(&self) -> f64

Upward cumulative sum accumulator.

pub fn s_low(&self) -> f64

Downward cumulative sum accumulator.

pub fn observe(&mut self, score: f64) -> DriftVerdict

Fold score into the detector and emit a verdict.

Non-finite inputs are silently ignored and return a verdict flagged as not-ready without mutating the detector.

pub fn reset(&mut self)

Clear the CUSUM accumulators while keeping the EMA reference intact. Call this after reacting to a drift event — the new distribution becomes the next reference.

pub fn reset_stats(&mut self)

Clear everything — accumulators and EMA reference. Returns the detector to its warmup state.

Trait Implementations

impl Clone for MetaDriftDetector

fn clone(&self) -> MetaDriftDetector

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MetaDriftDetector

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MetaDriftDetector

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MetaDriftDetector

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.