Struct StreamingAnomalyEngine 

pub struct StreamingAnomalyEngine { /* private fields */ }

Real-time streaming anomaly detection engine.

Processes CDC write events and runs per-series anomaly detection, emitting AnomalyScore results.

Implementations

impl StreamingAnomalyEngine

pub fn new() -> Self

Create a new streaming anomaly engine.

pub fn enable(&self, config: StreamingAnomalyConfig) -> Result<()>

Enable streaming anomaly detection for a measurement.

pub fn disable(&self, measurement: &str)

Disable streaming anomaly detection for a measurement.

pub fn is_enabled(&self, measurement: &str) -> bool

Check if a measurement has streaming anomaly detection enabled.

pub fn process_write( &self, measurement: &str, tags: &BTreeMap<String, String>, fields: &BTreeMap<String, FieldValue>, timestamp: i64, ) -> Option<ScoredAnomaly>

Process a CDC write event.

Returns the anomaly score if detection was performed (i.e., the series has enough data and is configured).

pub fn scores(&self) -> Vec<ScoredAnomaly>

Get all scored anomalies.

pub fn scores_for_measurement(&self, measurement: &str) -> Vec<ScoredAnomaly>

Get anomaly scores for a measurement.

pub fn anomalies(&self) -> Vec<ScoredAnomaly>

Get only anomalous scores.

pub fn config_count(&self) -> usize

Number of configured measurements.

pub fn series_count(&self) -> usize

Number of tracked series.

pub fn drain_scores(&self) -> Vec<ScoredAnomaly>

Drain all scores.

Trait Implementations

impl Default for StreamingAnomalyEngine

fn default() -> Self

Returns the “default value” for a type.