Versions in this module Expand all Collapse all v0 v0.0.2 Nov 11, 2022 Changes in this version + type OptionPrioQueue func(*PrioQueue) error + func OptionQueueLen(length int) OptionPrioQueue + type PrioQueue struct + func NewPrioQueue(opts ...OptionPrioQueue) (*PrioQueue, error) + func (pq *PrioQueue) Available() int + func (pq *PrioQueue) Len() int + func (pq *PrioQueue) Pop() interface{} + func (pq *PrioQueue) PopSync() interface{} + func (pq *PrioQueue) PrioPush(prio int, data interface{}) error + func (pq *PrioQueue) Push(data interface{}) error