Method createUserRequestQueue

pkg/scheduler/queue/user_queues.go:210–218

(userID string)

}

func (q *queues) createUserRequestQueue(userID string) userRequestQueue {
	if q.limits.QueryPriority(userID).Enabled {
		return NewPriorityRequestQueue(util.NewPriorityQueue(nil), userID, q.queueLength)
	}

	queueSize := q.limits.MaxOutstandingPerTenant(userID)

	return NewFIFORequestQueue(make(chan Request, queueSize), userID, q.queueLength)
}

// Finds next queue for the querier. To support fair scheduling between users, client is expected
// to pass last user index returned by this function as argument. Is there was no previous