Function getOrAdd

pkg/scheduler/queue/user_queues_test.go:502–508

(t *testing.T, uq *queues, tenant string, maxQueriers int)

}

func getOrAdd(t *testing.T, uq *queues, tenant string, maxQueriers int) userRequestQueue {
	q := uq.getOrAddQueue(tenant, maxQueriers)
	assert.NotNil(t, q)
	assert.NoError(t, isConsistent(uq))
	assert.Equal(t, q, uq.getOrAddQueue(tenant, maxQueriers))
	return q
}

func confirmOrderForQuerier(t *testing.T, uq *queues, querier string, lastUserIndex int, qs ...userRequestQueue) int {
	var n userRequestQueue