(u *userTSDB, metric labels.Labels)
| 233 | } |
| 234 | |
| 235 | func (m *labelSetCounter) decreaseSeriesLabelSet(u *userTSDB, metric labels.Labels) { |
| 236 | limits := m.limiter.limitsPerLabelSets(u.userID, metric) |
| 237 | for _, l := range limits { |
| 238 | s := m.shards[util.HashFP(model.Fingerprint(l.Hash))%numMetricCounterShards] |
| 239 | s.Lock() |
| 240 | if e, ok := s.valuesCounter[l.Hash]; ok { |
| 241 | e.count-- |
| 242 | } |
| 243 | s.Unlock() |
| 244 | } |
| 245 | } |
| 246 | |
| 247 | func (m *labelSetCounter) UpdateMetric(ctx context.Context, u *userTSDB, metrics *ingesterMetrics) error { |
| 248 | currentLbsLimitHash := map[uint64]validation.LimitsPerLabelSet{} |
no test coverage detected