Versions in this module Expand all Collapse all v1 v1.0.0 Jul 7, 2024 Changes in this version + const DefaultPriority + func MustPriorityEnqueue(queue PriorityEnqueuer, item interface{}, priority int, done <-chan struct{}, ...) bool + func MustPriorityEnqueueEvent(queue interface{ ... }, item interface{}, priority int, done <-chan struct{}) bool + func MustPriorityEnqueueMultiple(queue PriorityEnqueuer, items []interface{}, priorities []int, ...) ([]interface{}, bool) + func MustPriorityEnqueueMultipleEvent(queue interface{ ... }, items []interface{}, priorities []int, ...) ([]interface{}, bool) + type ByEnqueuedAt []*Wrapper + func (b ByEnqueuedAt) Len() int + func (b ByEnqueuedAt) Less(i, j int) bool + func (b ByEnqueuedAt) Swap(i, j int) + type ByPriority []*Wrapper + func (b ByPriority) Len() int + func (b ByPriority) Less(i, j int) bool + func (b ByPriority) Swap(i, j int) + type PriorityEnqueuer interface + PriorityEnqueue func(item interface{}, priority ...int) (overflow bool) + PriorityEnqueueMultiple func(items []interface{}, priority ...int) (itemsRemaining []interface{}, overflow bool) + type Wrapper struct + EnqueuedAt int64 + Item interface{} + Priority int
Go to main page