queue

type TimeQueue ¶

type TimeQueue interface {
	Add(t time.Time, ch chan<- time.Time) func() bool
	PopBeforeOrEqual(t time.Time) []chan<- time.Time
	Peek() (time.Time, bool)
	Len() int
}

TimeQueue is a priority queue of channels order by their trigger time. Not concurrent safe.

func NewTimeQueue() TimeQueue