Function confirmOrderForQuerier

pkg/scheduler/queue/user_queues_test.go:510–518

(t *testing.T, uq *queues, querier string, lastUserIndex int, qs ...userRequestQueue)

}

func confirmOrderForQuerier(t *testing.T, uq *queues, querier string, lastUserIndex int, qs ...userRequestQueue) int {
	var n userRequestQueue
	for _, q := range qs {
		n, _, lastUserIndex = uq.getNextQueueForQuerier(lastUserIndex, querier)
		assert.Equal(t, q, n)
		assert.NoError(t, isConsistent(uq))
	}
	return lastUserIndex
}

func isConsistent(uq *queues) error {
	if len(uq.sortedQueriers) != len(uq.queriers) {