Struct WindowId 

pub struct WindowId {
    pub start: i64,
    pub end: i64,
}

Unique identifier for a window.

Windows are identified by their start and end timestamps (in milliseconds). For tumbling windows, these are non-overlapping intervals.

Fields

start: i64

Window start timestamp (inclusive, in milliseconds)

end: i64

Window end timestamp (exclusive, in milliseconds)

Implementations

impl WindowId

pub fn new(start: i64, end: i64) -> Self

Creates a new window ID.

pub fn duration_ms(&self) -> i64

Returns the window duration in milliseconds.

pub fn to_key(&self) -> TimerKey

Converts the window ID to a byte key for state storage.

Uses TimerKey (SmallVec) which stores the 16-byte key inline, avoiding heap allocation on the hot path.

pub fn to_key_inline(&self) -> [u8; 16]

Converts the window ID to a stack-allocated byte key.

This is the zero-allocation version for Ring 0 hot path operations. Returns a fixed-size array that can be used directly with state stores.

pub fn from_key(key: &[u8]) -> Option<Self>

Parses a window ID from a byte key.

Errors

Returns None if the key is not exactly 16 bytes.

Trait Implementations

impl Archive for WindowId

where i64: Archive,

const COPY_OPTIMIZATION: CopyOptimization<Self>

An optimization flag that allows the bytes of this type to be copied directly to a writer instead of calling serialize.

type Archived = ArchivedWindowId

The archived representation of this type.

type Resolver = WindowIdResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

fn resolve(&self, resolver: Self::Resolver, out: Place<Self::Archived>)

Creates the archived version of this value at the given position and writes it to the given output.

impl Clone for WindowId

fn clone(&self) -> WindowId

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowId

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

Formats the value using the given formatter.

impl<__D: Fallible + ?Sized> Deserialize<WindowId, __D> for Archived<WindowId>

where i64: Archive, <i64 as Archive>::Archived: Deserialize<i64, __D>,

fn deserialize( &self, deserializer: &mut __D, ) -> Result<WindowId, <__D as Fallible>::Error>

Deserializes using the given deserializer

impl Hash for WindowId

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for WindowId

fn eq(&self, other: &WindowId) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__S: Fallible + ?Sized> Serialize<__S> for WindowId

where i64: Serialize<__S>,

fn serialize( &self, serializer: &mut __S, ) -> Result<<Self as Archive>::Resolver, <__S as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl Copy for WindowId

impl Eq for WindowId

impl StructuralPartialEq for WindowId