sliding_window

type SequenceGenerator struct {
	// contains filtered or unexported fields
}

type Watermark struct {
	ProcessTime time.Time
	EventTime   time.Time
}

type Window interface {
	AddWindowItem(item WindowItem)
	AckWindowItem(sequence int64)
	Size() int
	WaitingQueueLen() int
	Close()
	Watermark() Watermark
}

type WindowItem interface {
	SequenceNumber() int64
	BeforeWindowMoveForward()
	EventTime() time.Time
	ProcessTime() time.Time
}