Versions in this module Expand all Collapse all v0 v0.1.0 Oct 3, 2023 Changes in this version + const HighPriority + const INVOKED + const LowPriority + const NormalPriority + const PROCESSING + func CtxPQueues(entry interface{}, ctx context.Context) context.Context + type ItemStatus string + type PQueues struct + SuperUserPQueue *PriorityQueue + UserPQueue *PriorityQueue + func NewPQueues() PQueues + func PQueuesInstance(ctx context.Context) *PQueues + type PriorityQueue struct + func (pq *PriorityQueue) FixIndexesInPQueue() + func (pq *PriorityQueue) Len() int + func (pq *PriorityQueue) Less(i, j int) bool + func (pq *PriorityQueue) Pop() interface{} + func (pq *PriorityQueue) ProcessQueue(requestLimit int64, timeLimit time.Duration, stop chan struct{}) + func (pq *PriorityQueue) Push(x interface{}) + func (pq *PriorityQueue) RemoveById(id string) error + func (pq *PriorityQueue) Swap(i, j int) + func (pq *PriorityQueue) WaitUntilInvoked(id string) (*QueueItem, error) + type PriorityQueueInterface interface + ProcessQueue func(requestLimit int64, timeLimit time.Duration, stop chan struct{}) + WaitUntilInvoked func(id string) (*QueueItem, error) + func NewPriorityQueue() PriorityQueueInterface + type QueueItem struct + Amount int + Args []interface{} + Func interface{} + Id string + Priority int + Response Response + type Response struct + Error error + Value interface{}
Go to main page