MCPcopy Create free account
hub / github.com/cortexproject/cortex / TestPriorityQueuePriorities2

Function TestPriorityQueuePriorities2

pkg/util/priority_queue_test.go:47–60  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

45}
46
47func TestPriorityQueuePriorities2(t *testing.T) {
48 queue := NewPriorityQueue(nil)
49 queue.Enqueue(simpleItem(2))
50 queue.Enqueue(simpleItem(1))
51 queue.Enqueue(simpleItem(2))
52
53 assert.Equal(t, simpleItem(2), queue.Peek().(simpleItem), "Expected to peek simpleItem(2)")
54 assert.Equal(t, simpleItem(2), queue.Dequeue().(simpleItem), "Expected to dequeue simpleItem(2)")
55 assert.Equal(t, simpleItem(2), queue.Dequeue().(simpleItem), "Expected to dequeue simpleItem(2)")
56 assert.Equal(t, simpleItem(1), queue.Dequeue().(simpleItem), "Expected to dequeue simpleItem(1)")
57
58 queue.Close()
59 assert.Nil(t, queue.Dequeue(), "Expect nil dequeue")
60}
61
62func TestPriorityQueueWait(t *testing.T) {
63 queue := NewPriorityQueue(nil)

Callers

nothing calls this directly

Calls 7

EnqueueMethod · 0.95
PeekMethod · 0.95
DequeueMethod · 0.95
CloseMethod · 0.95
NewPriorityQueueFunction · 0.85
simpleItemTypeAlias · 0.85
EqualMethod · 0.65

Tested by

no test coverage detected