Function TestRing

internal/ring/ring_test.go:8–70

(t *testing.T)

)

func TestRing(t *testing.T) {
	type op = ringOp[int]
	testRing(t, New[int](3),
		// noops on empty ring
		op{cap: 0, opType: opRst, value: 0, items: []int{}},
		op{cap: 0, opType: opDeq, value: 0, items: []int{}},

		// basic
		op{cap: 3, opType: opEnq, value: 1, items: []int{1}},
		op{cap: 3, opType: opDeq, value: 1, items: []int{}},

		// wrapping
		op{cap: 3, opType: opEnq, value: 2, items: []int{2}},
		op{cap: 3, opType: opEnq, value: 3, items: []int{2, 3}},
		op{cap: 3, opType: opEnq, value: 4, items: []int{2, 3, 4}},
		op{cap: 3, opType: opDeq, value: 2, items: []int{3, 4}},
		op{cap: 3, opType: opDeq, value: 3, items: []int{4}},
		op{cap: 3, opType: opDeq, value: 4, items: []int{}},

		// resetting
		op{cap: 3, opType: opEnq, value: 2, items: []int{2}},
		op{cap: 3, opType: opRst, value: 0, items: []int{}},
		op{cap: 3, opType: opDeq, value: 0, items: []int{}},

		// growing without wrapping
		op{cap: 3, opType: opEnq, value: 5, items: []int{5}},
		op{cap: 3, opType: opEnq, value: 6, items: []int{5, 6}},
		op{cap: 3, opType: opEnq, value: 7, items: []int{5, 6, 7}},
		op{cap: 6, opType: opEnq, value: 8, items: []int{5, 6, 7, 8}},
		op{cap: 6, opType: opRst, value: 0, items: []int{}},
		op{cap: 6, opType: opDeq, value: 0, items: []int{}},

		// growing and wrapping
		op{cap: 6, opType: opEnq, value: 9, items: []int{9}},
		op{cap: 6, opType: opEnq, value: 10, items: []int{9, 10}},
		op{cap: 6, opType: opEnq, value: 11, items: []int{9, 10, 11}},
		op{cap: 6, opType: opEnq, value: 12, items: []int{9, 10, 11, 12}},
		op{cap: 6, opType: opEnq, value: 13, items: []int{9, 10, 11, 12, 13}},
		op{cap: 6, opType: opEnq, value: 14, items: []int{9, 10, 11, 12, 13, 14}},
		op{cap: 6, opType: opDeq, value: 9, items: []int{10, 11, 12, 13, 14}},
		op{cap: 6, opType: opDeq, value: 10, items: []int{11, 12, 13, 14}},
		op{cap: 6, opType: opEnq, value: 15, items: []int{11, 12, 13, 14, 15}},
		op{cap: 6, opType: opEnq, value: 16, items: []int{11, 12, 13, 14, 15, 16}},
		op{cap: 9, opType: opEnq, value: 17, items: []int{11, 12, 13, 14, 15, 16, 17}}, // grows wrapped
		op{cap: 9, opType: opDeq, value: 11, items: []int{12, 13, 14, 15, 16, 17}},
		op{cap: 9, opType: opDeq, value: 12, items: []int{13, 14, 15, 16, 17}},
		op{cap: 9, opType: opDeq, value: 13, items: []int{14, 15, 16, 17}},
		op{cap: 9, opType: opDeq, value: 14, items: []int{15, 16, 17}},
		op{cap: 9, opType: opDeq, value: 15, items: []int{16, 17}},
		op{cap: 9, opType: opDeq, value: 16, items: []int{17}},
		op{cap: 9, opType: opDeq, value: 17, items: []int{}},
		op{cap: 9, opType: opDeq, value: 0, items: []int{}},
	)

	t.Run("should panic on invalid chunkSize", func(t *testing.T) {
		defer func() {
			if r := recover(); r == nil {
				t.Fatalf("should have panicked")