Struct StreamingAnomalyConfig 

pub struct StreamingAnomalyConfig {
    pub measurement: String,
    pub field: Option<String>,
    pub detector_type: DetectorType,
    pub threshold: f64,
    pub enabled: bool,
    pub min_fit_points: usize,
    pub max_buffer_size: usize,
    pub refit_interval: usize,
}

Configuration for streaming anomaly detection on a measurement.

Fields

measurement: String

Measurement to monitor.

field: Option<String>

Which field to watch (default: first f64 field).

detector_type: DetectorType

Detector type to use.

threshold: f64

Anomaly threshold (meaning depends on detector type).

enabled: bool

Whether streaming is enabled.

min_fit_points: usize

Minimum data points before detection starts.

max_buffer_size: usize

Maximum buffer size for training data per series (prevents unbounded growth).

refit_interval: usize

Re-fit the detector every N new observations for concept drift adaptation. Set to 0 to disable periodic re-fit (only fit once).

Implementations

impl StreamingAnomalyConfig

pub fn new( measurement: impl Into<String>, detector_type: DetectorType, threshold: f64, ) -> Self

Create a new config.

pub fn with_field(self, field: impl Into<String>) -> Self

Set the field to monitor.

pub fn with_min_fit_points(self, n: usize) -> Self

Set minimum fit points.

pub fn with_max_buffer_size(self, n: usize) -> Self

Set maximum buffer size per series.

pub fn with_refit_interval(self, n: usize) -> Self

Set re-fit interval (number of new observations between re-fits). Set to 0 to disable periodic re-fit.

Trait Implementations

impl Clone for StreamingAnomalyConfig

fn clone(&self) -> StreamingAnomalyConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingAnomalyConfig

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

Formats the value using the given formatter.