(m metric)
| 220 | } |
| 221 | |
| 222 | func (r *ManagedRegistry) registerMetric(m metric) { |
| 223 | r.metricsMtx.Lock() |
| 224 | defer r.metricsMtx.Unlock() |
| 225 | |
| 226 | if old, ok := r.metrics[m.name()]; ok { |
| 227 | level.Info(r.logger).Log("msg", "replacing metric, counters will be reset", "metric", m.name()) |
| 228 | // Drain old series so the limiter's active count is properly decremented. |
| 229 | old.removeStaleSeries(math.MaxInt64) |
| 230 | } |
| 231 | r.metrics[m.name()] = m |
| 232 | } |
| 233 | |
| 234 | func (r *ManagedRegistry) CollectMetrics(ctx context.Context) { |
| 235 | r.metricsMtx.RLock() |
no test coverage detected