Method updateActiveSeries

pkg/ingester/ingester.go:1140–1156

(ctx context.Context)

}

func (i *Ingester) updateActiveSeries(ctx context.Context) {
	purgeTime := time.Now().Add(-i.cfg.ActiveSeriesMetricsIdleTimeout)

	for _, userID := range i.getTSDBUsers() {
		userDB, err := i.getTSDB(userID)
		if err != nil || userDB == nil {
			continue
		}

		userDB.activeSeries.Purge(purgeTime)
		i.metrics.activeSeriesPerUser.WithLabelValues(userID).Set(float64(userDB.activeSeries.Active()))
		i.metrics.activeNHSeriesPerUser.WithLabelValues(userID).Set(float64(userDB.activeSeries.ActiveNativeHistogram()))
		if err := userDB.labelSetCounter.UpdateMetric(ctx, userDB, i.metrics); err != nil {
			level.Warn(i.logger).Log("msg", "failed to update per labelSet metrics", "user", userID, "err", err)
		}
	}
}

func (i *Ingester) updateActiveQueriedSeries(ctx context.Context) {
	now := time.Now()