queues

Documentation

Index

• type CorePriorityQueue
  • func NewCorePriorityQueue[T any](options schema.GPQOptions, diskCache *disk.Disk[T], ...) CorePriorityQueue[T]
  • func (cpq *CorePriorityQueue[T]) ActiveBuckets() uint
  • func (cpq *CorePriorityQueue[T]) Dequeue() (*schema.Item[T], error)
  • func (cpq *CorePriorityQueue[T]) DequeueBatch(batchSize uint) ([]*schema.Item[T], []error)
  • func (cpq *CorePriorityQueue[T]) Enqueue(data *schema.Item[T]) error
  • func (cpq *CorePriorityQueue[T]) EnqueueBatch(data []*schema.Item[T]) []error
  • func (cpq *CorePriorityQueue[T]) ItemsInQueue() uint
  • func (cpq *CorePriorityQueue[T]) Prioritize() (removed uint, escalated uint, err error)

Types

type CorePriorityQueue

type CorePriorityQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewCorePriorityQueue

func NewCorePriorityQueue[T any](options schema.GPQOptions, diskCache *disk.Disk[T], deleteChan chan schema.DeleteMessage) CorePriorityQueue[T]

func (*CorePriorityQueue[T]) ActiveBuckets

func (cpq *CorePriorityQueue[T]) ActiveBuckets() uint

func (*CorePriorityQueue[T]) Dequeue

func (cpq *CorePriorityQueue[T]) Dequeue() (*schema.Item[T], error)

func (*CorePriorityQueue[T]) DequeueBatch

func (cpq *CorePriorityQueue[T]) DequeueBatch(batchSize uint) ([]*schema.Item[T], []error)

func (*CorePriorityQueue[T]) Enqueue

func (cpq *CorePriorityQueue[T]) Enqueue(data *schema.Item[T]) error

func (*CorePriorityQueue[T]) EnqueueBatch

func (cpq *CorePriorityQueue[T]) EnqueueBatch(data []*schema.Item[T]) []error

func (*CorePriorityQueue[T]) ItemsInQueue

func (cpq *CorePriorityQueue[T]) ItemsInQueue() uint

func (*CorePriorityQueue[T]) Prioritize

func (cpq *CorePriorityQueue[T]) Prioritize() (removed uint, escalated uint, err error)