Home
last modified time | relevance | path

Searched refs:connectedQuerierWorkers (Results 1 – 2 of 2) sorted by relevance

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/scheduler/queue/
H A Dqueue.go52 connectedQuerierWorkers *atomic.Int32 member
66 connectedQuerierWorkers: atomic.NewInt32(0),
181 for q.queues.len() > 0 && q.connectedQuerierWorkers.Load() > 0 {
195 q.connectedQuerierWorkers.Inc()
203 q.connectedQuerierWorkers.Dec()
222 return float64(q.connectedQuerierWorkers.Load())
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/scheduler/queue/
H A Dqueue.go52 connectedQuerierWorkers *atomic.Int32 member
66 connectedQuerierWorkers: atomic.NewInt32(0),
181 for q.queues.len() > 0 && q.connectedQuerierWorkers.Load() > 0 {
195 q.connectedQuerierWorkers.Inc()
203 q.connectedQuerierWorkers.Dec()
222 return float64(q.connectedQuerierWorkers.Load())