Versions in this module Expand all Collapse all v1 v1.1.1 Feb 7, 2026 Changes in this version + type PQItem struct + type PriorityQueue []*PQItem + func (pq *PriorityQueue) Pop() any + func (pq *PriorityQueue) Push(x any) + func (pq PriorityQueue) Len() int + func (pq PriorityQueue) Less(i, j int) bool + func (pq PriorityQueue) Swap(i, j int) + type ThreadSafePriorityQueue struct + func NewThreadSafePriorityQueue(logger *logrus.Logger) *ThreadSafePriorityQueue + func (tspq *ThreadSafePriorityQueue) Add(item *models.WorkItem) + func (tspq *ThreadSafePriorityQueue) Close() + func (tspq *ThreadSafePriorityQueue) Len() int + func (tspq *ThreadSafePriorityQueue) Pop() (*models.WorkItem, bool)
Go to main page