stopIncomingRequests is called during the shutdown process.
()
| 3735 | |
| 3736 | // stopIncomingRequests is called during the shutdown process. |
| 3737 | func (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. |
| 3744 | func metadataQueryRange(queryStart, queryEnd int64, db *userTSDB, queryIngestersWithin time.Duration) (mint, maxt int64, err error) { |