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

Method stopIncomingRequests

pkg/ingester/ingester.go:3737–3741  ·  view source on GitHub ↗

stopIncomingRequests is called during the shutdown process.

()

Source from the content-addressed store, hash-verified

3735
3736// stopIncomingRequests is called during the shutdown process.
3737func (i *Ingester) stopIncomingRequests() {
3738 i.stoppedMtx.Lock()
3739 defer i.stoppedMtx.Unlock()
3740 i.stopped = true
3741}
3742
3743// metadataQueryRange returns the best range to query for metadata queries based on the timerange in the ingester.
3744func metadataQueryRange(queryStart, queryEnd int64, db *userTSDB, queryIngestersWithin time.Duration) (mint, maxt int64, err error) {

Callers 1

stoppingMethod · 0.95

Implementers 1

Ingesterpkg/ingester/ingester.go

Calls

no outgoing calls

Tested by

no test coverage detected