Method canAddSeriesForLabelSet

pkg/ingester/user_state.go:118–131

(ctx context.Context, u *userTSDB, metric labels.Labels)

}

func (m *labelSetCounter) canAddSeriesForLabelSet(ctx context.Context, u *userTSDB, metric labels.Labels) error {
	return m.limiter.AssertMaxSeriesPerLabelSet(u.userID, metric, func(allLimits []validation.LimitsPerLabelSet, limit validation.LimitsPerLabelSet) (int, error) {
		s := m.shards[util.HashFP(model.Fingerprint(limit.Hash))%numMetricCounterShards]
		s.RLock()
		if r, ok := s.valuesCounter[limit.Hash]; ok {
			defer s.RUnlock()
			return r.count, nil
		}
		s.RUnlock()

		// We still dont keep track of this label value so we need to backfill
		return m.backFillLimit(ctx, u, false, allLimits, limit, s)
	})
}

func (m *labelSetCounter) backFillLimit(ctx context.Context, u *userTSDB, forceBackfill bool, allLimits []validation.LimitsPerLabelSet, limit validation.LimitsPerLabelSet, s *labelSetCounterShard) (int, error) {
	s.Lock()