(context.Context)
| 289 | } |
| 290 | |
| 291 | func (r *ManagedRegistry) removeStaleSeries(context.Context) { |
| 292 | r.metricsMtx.RLock() |
| 293 | defer r.metricsMtx.RUnlock() |
| 294 | |
| 295 | timeMs := time.Now().Add(-1 * r.cfg.StaleDuration).UnixMilli() |
| 296 | |
| 297 | remainingSeries := 0 |
| 298 | for _, m := range r.metrics { |
| 299 | m.removeStaleSeries(timeMs) |
| 300 | remainingSeries += m.countActiveSeries() |
| 301 | } |
| 302 | r.entityDemand.Advance() |
| 303 | |
| 304 | level.Info(r.logger).Log("msg", "deleted stale series", "active_series", remainingSeries) |
| 305 | } |
| 306 | |
| 307 | func (r *ManagedRegistry) Close() { |
| 308 | level.Info(r.logger).Log("msg", "closing registry") |
nothing calls this directly
no test coverage detected