Struct SensorFluxProcessor 

pub struct SensorFluxProcessor { /* private fields */ }

Available on crate feature flux only.

Sensor-aware Flux processor for baseline tracking and HSI enrichment.

Implementations

impl SensorFluxProcessor

pub fn new(baseline_window_sessions: usize) -> Self

Create a new processor with the specified baseline window size.

Arguments

• baseline_window_sessions - Number of sessions to include in rolling baseline (default: 20)

pub fn with_device_id(baseline_window_sessions: usize, device_id: &str) -> Self

Create with a custom device ID.

pub fn process_window( &mut self, window: &EventWindow, _features: &WindowFeatures, base_snapshot: HsiSnapshot, ) -> Result<EnrichedSnapshot, ComputeError>

Process a window and return an enriched snapshot with flux metrics.

This converts the sensor window to a behavior session, processes it through the flux pipeline, and returns an enriched snapshot.

pub fn update_baseline( &mut self, window: &EventWindow, ) -> Result<(), ComputeError>

Process a window without enrichment (just baseline update).

This updates the baseline without returning enriched output.

pub fn save_baselines(&self) -> Result<String, ComputeError>

Save baselines to JSON for persistence.

pub fn load_baselines(&mut self, json: &str) -> Result<(), ComputeError>

Load baselines from JSON.

pub fn session_count(&self) -> usize

Get the number of sessions processed.

Trait Implementations

impl Default for SensorFluxProcessor

fn default() -> Self

Returns the “default value” for a type.