MCPcopy Create free account
hub / github.com/cortexproject/cortex / RegisterQuerierConnection

Method RegisterQuerierConnection

pkg/scheduler/queue/queue.go:220–226  ·  view source on GitHub ↗
(querier string)

Source from the content-addressed store, hash-verified

218}
219
220func (q *RequestQueue) RegisterQuerierConnection(querier string) {
221 q.connectedQuerierWorkers.Inc()
222
223 q.mtx.Lock()
224 defer q.mtx.Unlock()
225 q.queues.addQuerierConnection(querier)
226}
227
228func (q *RequestQueue) UnregisterQuerierConnection(querier string) {
229 q.connectedQuerierWorkers.Dec()

Callers 11

BenchmarkGetNextRequestFunction · 0.95
BenchmarkQueueRequestFunction · 0.95
BenchmarkGetNextRequestPriorityQueueFunction · 0.95
BenchmarkQueueRequestPriorityQueueFunction · 0.95
TestRequestQueue_GetNextRequestForQuerier_ShouldGetRequestAfterReshardingBecauseQuerierHasBeenForgottenFunction · 0.95
TestQueriersShouldGetHighPriorityQueryFirstFunction · 0.95
TestReservedQueriersShouldOnlyGetHighPriorityQueriesFunction · 0.95
TestExitingRequestsShouldPersistEvenIfTheConfigHasChangedFunction · 0.95
QuerierLoopMethod · 0.80
ProcessMethod · 0.80
TestFrontendCheckReadyFunction · 0.80

Calls 2

addQuerierConnectionMethod · 0.80
IncMethod · 0.45

Tested by 9

BenchmarkGetNextRequestFunction · 0.76
BenchmarkQueueRequestFunction · 0.76
BenchmarkGetNextRequestPriorityQueueFunction · 0.76
BenchmarkQueueRequestPriorityQueueFunction · 0.76
TestRequestQueue_GetNextRequestForQuerier_ShouldGetRequestAfterReshardingBecauseQuerierHasBeenForgottenFunction · 0.76
TestQueriersShouldGetHighPriorityQueryFirstFunction · 0.76
TestReservedQueriersShouldOnlyGetHighPriorityQueriesFunction · 0.76
TestExitingRequestsShouldPersistEvenIfTheConfigHasChangedFunction · 0.76
TestFrontendCheckReadyFunction · 0.64