Struct PerFeatureCusum 

pub struct PerFeatureCusum<const D: usize> { /* private fields */ }

D parallel two-sided CUSUMs sharing one (slack, threshold) configuration.

Examples

use anomstream_core::{PerFeatureCusum, PerFeatureCusumConfig};

let mut det = PerFeatureCusum::<2>::new(PerFeatureCusumConfig {
    slack: 0.5,
    threshold: 5.0,
});
det.observe(&[100.0, 200.0]); // seeds references
for _ in 0..20 {
    det.observe(&[105.0, 200.0]);
}

Implementations

impl<const D: usize> PerFeatureCusum<D>

pub const fn new(config: PerFeatureCusumConfig) -> Self

Build an empty detector.

pub const fn config(&self) -> &PerFeatureCusumConfig

Active configuration.

pub const fn total_samples(&self) -> u64

Observations ingested so far.

pub const fn accumulators(&self) -> &[PerFeatureCusumAccumulator; D]

Per-dimension accumulator snapshot (read-only).

pub fn active_drifts(&self) -> usize

Count of features currently in an active drift (drift_samples > 0).

pub fn set_reference(&mut self, means: &[f64; D])

Override the auto-learned reference mean per dimension. Useful when feeding a stable external baseline (e.g. an EWMA mean) rather than the first observation.

pub fn observe(&mut self, input: &[f64; D]) -> PerFeatureCusumResult<D>

Ingest input, returning per-feature magnitudes and any alerts that fired. Always updates the accumulators.

pub fn reset(&mut self)

Zero every accumulator and the sample counter.

Trait Implementations

impl<const D: usize> Clone for PerFeatureCusum<D>

fn clone(&self) -> PerFeatureCusum<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<const D: usize> Debug for PerFeatureCusum<D>

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

Formats the value using the given formatter.

impl<'de, const D: usize> Deserialize<'de> for PerFeatureCusum<D>

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<const D: usize> Serialize for PerFeatureCusum<D>

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

where __S: Serializer,

Serialize this value into the given Serde serializer.