Function newUserQueues

pkg/scheduler/queue/user_queues.go:87–97

(forgetDelay time.Duration, limits Limits, queueLength *prometheus.GaugeVec)

}

func newUserQueues(forgetDelay time.Duration, limits Limits, queueLength *prometheus.GaugeVec) *queues {
	return &queues{
		userQueues:     map[string]*userQueue{},
		users:          nil,
		forgetDelay:    forgetDelay,
		queriers:       map[string]*querier{},
		sortedQueriers: nil,
		limits:         limits,
		queueLength:    queueLength,
	}
}

func (q *queues) len() int {
	return len(q.userQueues)