Module window_manager 

Generic window manager for time-series aggregations

Provides windowing operations for streaming data:

• Tumbling (fixed non-overlapping)
• Sliding (overlapping)
• Session (gap-based)
• Count-based
• Cumulative

This module is industry-agnostic and works with any timestamped data.

Structs

AggregateSpec

Aggregation specification

WindowDataPoint

A single data point in a window

WindowManager

Generic window manager for streaming aggregations

WindowResult

A completed window with aggregated data

Enums

AggregateFunction

Aggregation function type

WindowType

Window type for aggregations