Struct TimeSeriesNormalizer 

pub struct TimeSeriesNormalizer { /* private fields */ }

Thread-safe time-series normalizer with out-of-order handling

Implementations

impl TimeSeriesNormalizer

pub fn new(config: NormalizationConfig) -> NormalizationResult<Self>

Create a new normalizer with the given configuration

pub fn default_config() -> NormalizationResult<Self>

Create a normalizer with default configuration

pub fn normalize(&self, event: TimeSeriesEvent) -> Result<Vec<TimeSeriesEvent>>

Process a single time-series event and return normalized events

This method may return multiple events if there were gaps that needed to be filled. It buffers out-of-order events and emits them when the watermark advances.

pub fn normalize_batch( &self, events: Vec<TimeSeriesEvent>, ) -> Result<Vec<TimeSeriesEvent>>

Process a batch of events

This is more efficient than calling normalize() repeatedly as it can optimize buffer operations and reduce lock contention.

pub fn flush(&self) -> Result<Vec<TimeSeriesEvent>>

Flush any remaining buffered events

This should be called at the end of a stream to ensure all buffered events are processed. It will emit events even if gaps remain.

pub fn stats(&self) -> Result<NormalizationStats>

Get current statistics

pub fn reset(&self) -> Result<()>

Reset the normalizer state

pub fn interval_ms(&self) -> Result<Option<i64>>

Get the detected or configured interval

Trait Implementations

impl Clone for TimeSeriesNormalizer

fn clone(&self) -> TimeSeriesNormalizer

Returns a duplicate of the value.

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

Performs copy-assignment from source.