memory

Oct 23, 2025

Changes in this version

+ type GroupNode struct

+ func NewGroupNode(name string, parent *GroupNode) *GroupNode

Oct 19, 2025

Changes in this version

type DelayedQueue

+ func (pq *DelayedQueue) UpdateMaxUnacked(maxUnacked int) error

type FairRoundRobinQueue

+ func (fq *FairRoundRobinQueue) UpdateMaxUnacked(maxUnacked int) error

type FairWeightedQueue

+ func (q *FairWeightedQueue) UpdateMaxUnacked(maxUnacked int) error

type MemoryQueue

+ UpdateMaxUnacked func(maxUnacked int) error

Jun 13, 2025

Changes in this version

+ func CalculateWeight(maxUnacked int, unacked int, queueSize int) int

+ type DelayedQueue struct

+ func NewDelayedQueue(minFirst bool) *DelayedQueue

+ func (pq *DelayedQueue) Delete(group string, id uint64) *Item

+ func (pq *DelayedQueue) Dequeue(ack bool) *Item

+ func (pq *DelayedQueue) Enqueue(group string, item *Item)

+ func (pq *DelayedQueue) Get(group string, id uint64) *Item

+ func (pq *DelayedQueue) Len() uint64

+ func (pq *DelayedQueue) UpdatePriority(group string, id uint64, priority int64)

+ func (pq *DelayedQueue) UpdateWeights(group string, id uint64) error

+ type FairRoundRobinQueue struct

+ func NewFairRoundRobinQueue(maxUnacked int) *FairRoundRobinQueue

+ func (fq *FairRoundRobinQueue) Delete(group string, id uint64) *Item

+ func (fq *FairRoundRobinQueue) Dequeue(ack bool) *Item

+ func (fq *FairRoundRobinQueue) Enqueue(group string, item *Item)

+ func (fq *FairRoundRobinQueue) Get(group string, id uint64) *Item

+ func (fq *FairRoundRobinQueue) Len() uint64

+ func (fq *FairRoundRobinQueue) UpdatePriority(group string, id uint64, priority int64)

+ func (fq *FairRoundRobinQueue) UpdateWeights(group string, id uint64) error

+ type FairWeightedQueue struct

+ func NewFairWeightedQueue(maxUnacked int) *FairWeightedQueue

+ func (q *FairWeightedQueue) Delete(group string, id uint64) *Item

+ func (q *FairWeightedQueue) Dequeue(ack bool) *Item

+ func (q *FairWeightedQueue) Enqueue(group string, item *Item)

+ func (q *FairWeightedQueue) Get(group string, id uint64) *Item

+ func (q *FairWeightedQueue) Len() uint64

+ func (q *FairWeightedQueue) UpdatePriority(group string, id uint64, priority int64)

+ func (q *FairWeightedQueue) UpdateWeights(group string, id uint64) error

type MemoryQueue

+ UpdateWeights func(group string, id uint64) error

Mar 5, 2025

Changes in this version

+ type DelayedMemoryQueue struct

+ func NewDelayedMemoryQueue(minFirst bool) *DelayedMemoryQueue

+ func (pq *DelayedMemoryQueue) Delete(group string, id uint64) *Item

+ func (pq *DelayedMemoryQueue) Dequeue() *Item

+ func (pq *DelayedMemoryQueue) Enqueue(group string, item *Item)

+ func (pq *DelayedMemoryQueue) Get(group string, id uint64) *Item

+ func (pq *DelayedMemoryQueue) Len() uint64

+ func (pq *DelayedMemoryQueue) UpdatePriority(group string, id uint64, priority int64)

+ type FairMemoryQueue struct

+ func NewFairMemoryQueue() *FairMemoryQueue

+ func (fq *FairMemoryQueue) Delete(group string, id uint64) *Item

+ func (fq *FairMemoryQueue) Dequeue() *Item

+ func (fq *FairMemoryQueue) Enqueue(group string, item *Item)

+ func (fq *FairMemoryQueue) Get(group string, id uint64) *Item

+ func (fq *FairMemoryQueue) Len() uint64

+ func (fq *FairMemoryQueue) UpdatePriority(group string, id uint64, priority int64)

+ type Item struct

+ Group string

+ ID uint64

+ Priority int64

+ func (m *Item) UpdatePriority(newPriority int64)

+ type LinkedList struct

+ func (l *LinkedList) Append(node *LinkedListNode)

+ func (l *LinkedList) Len() uint64

+ func (l *LinkedList) Remove(node *LinkedListNode)

+ type LinkedListNode struct

+ func NewLinkedListNode(group string, queue *PriorityMemoryQueue) *LinkedListNode

+ func (n *LinkedListNode) Queue() *PriorityMemoryQueue

+ type MemoryQueue interface

+ Delete func(group string, id uint64) *Item

+ Dequeue func() *Item

+ Enqueue func(group string, item *Item)

+ Get func(group string, id uint64) *Item

+ Len func() uint64

+ UpdatePriority func(group string, id uint64, priority int64)

+ type PriorityMemoryQueue struct

+ func NewPriorityMemoryQueue(minFirst bool) *PriorityMemoryQueue

+ func (pq *PriorityMemoryQueue) Delete(id uint64) *Item

+ func (pq *PriorityMemoryQueue) Get(id uint64) *Item

+ func (pq *PriorityMemoryQueue) Peek() any

+ func (pq *PriorityMemoryQueue) Pop() any

+ func (pq *PriorityMemoryQueue) Push(x any)

+ func (pq *PriorityMemoryQueue) UpdatePriority(id uint64, priority int64)

+ func (pq PriorityMemoryQueue) Len() int

+ func (pq PriorityMemoryQueue) Less(i, j int) bool

+ func (pq PriorityMemoryQueue) Swap(i, j int)