Versions in this module Expand all Collapse all v1 v1.1.14 Oct 6, 2022 Changes in this version + type LazyQueue struct + func NewLazyQueue(setIndex SetIndexCallback, priority PriorityCallback, ...) *LazyQueue + func (q *LazyQueue) Empty() bool + func (q *LazyQueue) MultiPop(callback func(data interface{}, priority int64) bool) + func (q *LazyQueue) Pop() (interface{}, int64) + func (q *LazyQueue) PopItem() interface{} + func (q *LazyQueue) Push(data interface{}) + func (q *LazyQueue) Refresh() + func (q *LazyQueue) Remove(index int) interface{} + func (q *LazyQueue) Reset() + func (q *LazyQueue) Size() int + func (q *LazyQueue) Update(index int) + type MaxPriorityCallback func(data interface{}, until mclock.AbsTime) int64 + type PriorityCallback func(data interface{}) int64 + type Prque struct + func New(setIndex SetIndexCallback) *Prque + func NewWrapAround(setIndex SetIndexCallback) *Prque + func (p *Prque) Empty() bool + func (p *Prque) Peek() (interface{}, int64) + func (p *Prque) Pop() (interface{}, int64) + func (p *Prque) PopItem() interface{} + func (p *Prque) Push(data interface{}, priority int64) + func (p *Prque) Remove(i int) interface{} + func (p *Prque) Reset() + func (p *Prque) Size() int + type SetIndexCallback func(data interface{}, index int)