Struct StreamingAnomalyDetector 

pub struct StreamingAnomalyDetector { /* private fields */ }

Streaming anomaly detector for real-time processing

Implementations

impl StreamingAnomalyDetector

pub fn new(detector: QuantumAnomalyDetector, config: RealtimeConfig) -> Self

Create new streaming anomaly detector

pub fn process_sample(&mut self, sample: Array1<f64>) -> Result<f64>

Process a single sample

pub fn process_batch(&mut self, batch: &Array2<f64>) -> Result<Array1<f64>>

Process a batch of samples

pub fn update_detector( &mut self, data: &Array2<f64>, labels: Option<&Array1<i32>>, ) -> Result<()>

Update the underlying detector with new labeled data

pub fn is_drift_detected(&self) -> bool

Check if drift is detected

pub fn buffer_size(&self) -> usize

Get buffer size

pub fn clear_buffer(&mut self)

Clear the buffer