Documentation ¶ Index ¶ type Item type Matcher type Queue func NewQueue(maxLen int, matchingFunc Matcher, removeMatched bool) *Queue func (q *Queue) AddFirst(data any, t time.Time) []Item func (q *Queue) AddSecond(data any, t time.Time) []Item Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Item ¶ type Item struct { Item any Timestamp time.Time } type Matcher ¶ type Matcher func(a, b any) bool type Queue ¶ type Queue struct { sync.Mutex // contains filtered or unexported fields } func NewQueue ¶ func NewQueue(maxLen int, matchingFunc Matcher, removeMatched bool) *Queue func (*Queue) AddFirst ¶ func (q *Queue) AddFirst(data any, t time.Time) []Item func (*Queue) AddSecond ¶ func (q *Queue) AddSecond(data any, t time.Time) []Item Source Files ¶ View all Source files queue.go Click to show internal directories. Click to hide internal directories.