Struct TumblingWindow 

pub struct TumblingWindow {
    pub window_ms: u64,
    /* private fields */
}

固定幅タンブリングウィンドウ。

ウィンドウ境界でMetricSlotをrotateし、完了したウィンドウを返す。

|---window 0---|---window 1---|---window 2---|
   ↑ events      ↑ events       ↑ events

Fields

window_ms: u64

ウィンドウ幅（ミリ秒）。

Implementations

impl TumblingWindow

pub fn new(window_ms: u64, alpha: f64) -> Self

新しいタンブリングウィンドウを作成。

pub fn insert(&mut self, value: f64, timestamp_ms: u64) -> Option<WindowResult>

イベントを投入。ウィンドウ境界を超えた場合、完了したスロットを返す。

時刻は saturating_add で足す: timestamp_ms が u64::MAX 近傍だと current_start + window_ms が溢れ、2026-10-07 までは debug build で panic し release build では wrap して境界時刻が巻き戻っていた 飽和させると最後のウィンドウが閉じなくなるだけで、flush() で取り出せる

pub fn flush(&mut self) -> WindowResult

現在のウィンドウを強制的にフラッシュ。

pub const fn current_count(&self) -> u64

現在のウィンドウのイベント数。