accumulate

func (*Windower) AssignWindows ¶

func (w *Windower) AssignWindows(message *isb.ReadMessage) []*window.TimedWindowRequest

AssignWindows assigns the windows for the given message. Since accumulator is based on the global window concept, we will have only one window per key.

func (*Windower) CloseWindows ¶

func (w *Windower) CloseWindows(currentTime time.Time) []*window.TimedWindowRequest

CloseWindows closes the windows that have expired based on the timeout and since the WM has progressed.

func (*Windower) DeleteClosedWindow ¶

func (w *Windower) DeleteClosedWindow(window window.TimedWindow)

DeleteClosedWindow deletes the event time entries from the window state till the window end time. Actual deletion of the state happens when the timeout expires.

func (*Windower) InsertWindow ¶

func (w *Windower) InsertWindow(_ window.TimedWindow)

InsertWindow inserts the window into the active windows. Since we have only one window for the key, it replaces the existing window.

func (*Windower) NextWindowToBeClosed ¶

func (w *Windower) NextWindowToBeClosed() window.TimedWindow

NextWindowToBeClosed returns the next window to be closed. Since accumulator is based on the global window concept, we don't have a window to be closed.

func (*Windower) OldestWindowEndTime ¶

func (w *Windower) OldestWindowEndTime() time.Time

OldestWindowEndTime returns the oldest event time among all the keyed windows.

func (*Windower) Strategy ¶

func (w *Windower) Strategy() window.Strategy

func (*Windower) Type ¶

func (w *Windower) Type() window.Type

Type returns the window type. Accumulator window falls under the unaligned window type since it doesn't have a fixed window size.