Method updateLoop

pkg/ingester/ingester.go:1034–1099

(ctx context.Context)

}

func (i *Ingester) updateLoop(ctx context.Context) error {
	rateUpdateTicker := time.NewTicker(i.cfg.RateUpdatePeriod)
	defer rateUpdateTicker.Stop()

	userTSDBConfigTicker := time.NewTicker(i.cfg.UserTSDBConfigsUpdatePeriod)
	defer userTSDBConfigTicker.Stop()

	ingestionRateTicker := time.NewTicker(instanceIngestionRateTickInterval)
	defer ingestionRateTicker.Stop()

	var activeSeriesTickerChan <-chan time.Time
	if i.cfg.ActiveSeriesMetricsEnabled {
		t := time.NewTicker(i.cfg.ActiveSeriesMetricsUpdatePeriod)
		activeSeriesTickerChan = t.C
		defer t.Stop()
	}

	var activeQueriedSeriesTickerChan <-chan time.Time
	if i.cfg.ActiveQueriedSeriesMetricsEnabled {
		t := time.NewTicker(i.cfg.ActiveQueriedSeriesMetricsUpdatePeriod)
		activeQueriedSeriesTickerChan = t.C
		defer t.Stop()
	}

	// Similarly to the above, this is a hardcoded value.
	metadataPurgeTicker := time.NewTicker(metadataPurgePeriod)
	defer metadataPurgeTicker.Stop()

	maxTrackerResetTicker := time.NewTicker(maxInflightRequestResetPeriod)
	defer maxTrackerResetTicker.Stop()

	labelSetMetricsTicker := time.NewTicker(labelSetMetricsTickInterval)
	defer labelSetMetricsTicker.Stop()

	for {
		select {
		case <-metadataPurgeTicker.C:
			i.purgeUserMetricsMetadata()
		case <-ingestionRateTicker.C:
			i.ingestionRate.Tick()
		case <-rateUpdateTicker.C:
			i.stoppedMtx.RLock()
			for _, db := range i.TSDBState.dbs {
				db.ingestedAPISamples.Tick()
				db.ingestedRuleSamples.Tick()
			}
			i.stoppedMtx.RUnlock()

		case <-activeSeriesTickerChan:
			i.updateActiveSeries(ctx)
		case <-activeQueriedSeriesTickerChan:
			i.updateActiveQueriedSeries(ctx)
		case <-maxTrackerResetTicker.C:
			i.maxInflightQueryRequests.Tick()
			i.maxInflightPushRequests.Tick()
		case <-userTSDBConfigTicker.C:
			i.updateUserTSDBConfigs()
		case <-labelSetMetricsTicker.C: