slidingwindow

type Window interface {
	// Start is the left position of the window.
	Start() uint

	// Size is the size of the window.
	Size() uint

	// Count is total count of events happened in the window.
	Count() uint

	// Len is the length of bitset.
	Len() uint

	// AddCount increments the accumulated count by n.
	AddCount(n uint)

	// IsFinished returns streaming window execution status.
	IsFinished() bool

	// WindowStatus describe the window status.
	Status() *WindowStatus
}

type WindowStatus struct {
	bitset.BitSet
	// contains filtered or unexported fields
}