Method UpdateLabelSet

pkg/util/validation/validate.go:209–222

(userSet map[string]map[uint64]struct{}, logger log.Logger)

}

func (m *ValidateMetrics) UpdateLabelSet(userSet map[string]map[uint64]struct{}, logger log.Logger) {
	m.LabelSetTracker.UpdateMetrics(userSet, func(user, labelSetStr string, removeUser bool) {
		if removeUser {
			// No need to clean up discarded samples per user here as it will be cleaned up elsewhere.
			if err := util.DeleteMatchingLabels(m.DiscardedSamplesPerLabelSet, map[string]string{"user": user}); err != nil {
				level.Warn(logger).Log("msg", "failed to remove cortex_discarded_samples_per_labelset_total metric for user", "user", user, "err", err)
			}
			return
		}
		if err := util.DeleteMatchingLabels(m.DiscardedSamplesPerLabelSet, map[string]string{"user": user, "labelset": labelSetStr}); err != nil {
			level.Warn(logger).Log("msg", "failed to remove cortex_discarded_samples_per_labelset_total metric", "user", user, "labelset", labelSetStr, "err", err)
		}
	})
}

// ValidateSampleTimestamp returns an err if the sample timestamp is invalid.
// The returned error may retain the provided series labels.