Struct TimeWindow 

pub struct TimeWindow {
    pub start: DateTime<Utc>,
    pub end: DateTime<Utc>,
    pub id: String,
}

Represents a time window

Fields

start: DateTime<Utc>

Window start time

end: DateTime<Utc>

Window end time

id: String

Window identifier

Implementations

impl TimeWindow

pub fn new(start: DateTime<Utc>, end: DateTime<Utc>) -> Self

Creates a new time window.

id is derived at nanosecond precision (falling back, saturating rather than overflowing/panicking, to a second-precision value for timestamps outside chrono’s nanosecond-representable range, such as the sentinel DateTime::MIN_UTC/MAX_UTC used for WindowType::Global). A second-precision id, as this used unconditionally before, can collide for two genuinely distinct windows that happen to start and end within the same wall-clock second – which is routine for count-based windows (see WindowedAggregator::process_count, whose windows’ start/end are the real observed event times of their records, often only microseconds apart under any real load) and for a burst of high-frequency tumbling/sliding windows.

pub fn contains(&self, timestamp: DateTime<Utc>) -> bool

Checks if a timestamp falls within this window

pub fn duration(&self) -> Duration

Gets the duration of the window

Trait Implementations

impl Clone for TimeWindow

fn clone(&self) -> TimeWindow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TimeWindow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TimeWindow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TimeWindow

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.