Struct Adwin 

pub struct Adwin { /* private fields */ }

Available on crate feature alloc only.

ADWIN (ADaptive WINdowing) drift detector.

Maintains an adaptive-size window over a stream of real-valued observations using an exponential histogram. Detects distribution shift by comparing sub-window means with a Hoeffding-style bound.

Examples

use irithyll_core::drift::{DriftDetector, DriftSignal};
use irithyll_core::drift::adwin::Adwin;

let mut det = Adwin::new();
// Feed stable values
for _ in 0..200 {
    let sig = det.update(0.0);
    assert_ne!(sig, DriftSignal::Drift);
}

Implementations

impl Adwin

pub fn new() -> Self

Create a new ADWIN detector with the default confidence delta = 0.002.

pub fn with_delta(delta: f64) -> Self

Create a new ADWIN detector with the given confidence parameter.

delta controls sensitivity: smaller values mean fewer false positives but slower reaction to real drift. Typical range: 0.0001 to 0.1.

Panics

Panics if delta is not in (0, 1).

pub fn with_max_buckets(self, m: usize) -> Self

Set the maximum number of buckets per row (default 5).

Higher values use more memory but give finer granularity for split-point testing. Must be at least 2.

pub fn with_min_window(self, min: u64) -> Self

Set the minimum window size before drift checking begins (default 32).

pub fn width(&self) -> u64

Current window width (number of original observations).

Trait Implementations

impl Clone for Adwin

fn clone(&self) -> Adwin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Adwin

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

Formats the value using the given formatter.

impl Default for Adwin

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Adwin

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Adwin

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

Formats the value using the given formatter.

impl DriftDetector for Adwin

fn update(&mut self, value: f64) -> DriftSignal

Feed a new value and get the current drift signal.

fn reset(&mut self)

Reset to initial state.

fn clone_fresh(&self) -> Box<dyn DriftDetector>

Create a fresh detector with the same configuration but no state.

fn clone_boxed(&self) -> Box<dyn DriftDetector>

Clone this detector including its internal state.

fn estimated_mean(&self) -> f64

Current estimated mean of the monitored stream.

fn serialize_state(&self) -> Option<DriftDetectorState>

Serialize the detector’s internal state for model persistence.

fn restore_state(&mut self, state: &DriftDetectorState) -> bool

Restore the detector’s internal state from a serialized snapshot.

impl Serialize for Adwin

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

where __S: Serializer,

Serialize this value into the given Serde serializer.