Struct TimeWindow 

pub struct TimeWindow {
    pub window_type: WindowType,
    pub duration: Duration,
    pub start_time: u64,
    pub end_time: u64,
    /* private fields */
}

Time-based window for event processing

Fields

window_type: WindowType

Window type

duration: Duration

Window duration

start_time: u64

Window start time (milliseconds since epoch)

end_time: u64

Window end time (milliseconds since epoch)

Implementations

impl TimeWindow

pub fn new( window_type: WindowType, duration: Duration, start_time: u64, max_events: usize, ) -> Self

Create a new time window

pub fn add_event(&mut self, event: StreamEvent) -> bool

Add event to window if it fits

pub fn record(&mut self, event: StreamEvent)

Records an event into a continuously sliding window: advances the trailing boundary to the event’s own timestamp and evicts anything older than duration, instead of rejecting events the way add_event does once [start_time, end_time) is stale.

add_event and WindowManager are built around a history of many fixed, non-advancing windows (useful for looking back at past windows later). record is for the opposite case: maintaining a single live value — “how many X in the trailing N seconds, as of right now” — which is what most rate/threshold rules actually need.

No-op on the boundary advance for non-Sliding window types (the event is still recorded); tumbling/session semantics don’t have a meaningful “trailing” window to advance.

pub fn contains_timestamp(&self, timestamp: u64) -> bool

Check if timestamp falls within this window

pub fn events(&self) -> &VecDeque<StreamEvent>

Get all events in window

pub fn count(&self) -> usize

Get event count

pub fn is_expired(&self, current_time: u64) -> bool

Check if window is expired

pub fn duration_ms(&self) -> u64

Get window duration in milliseconds

pub fn clear(&mut self)

Clear all events from window

pub fn events_by_type(&self, event_type: &str) -> Vec<&StreamEvent>

Get events filtered by type

pub fn sum(&self, field: &str) -> f64

Calculate sum of numeric field across events

pub fn average(&self, field: &str) -> Option<f64>

Calculate average of numeric field across events

pub fn min(&self, field: &str) -> Option<f64>

Find minimum value of numeric field

pub fn max(&self, field: &str) -> Option<f64>

Find maximum value of numeric field

pub fn latest_timestamp(&self) -> Option<u64>

Get the latest event timestamp

pub fn events_in_range(&self, start: u64, end: u64) -> Vec<&StreamEvent>

Get events within a sub-window

Trait Implementations

impl Debug for TimeWindow

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

Formats the value using the given formatter.