(staleTimeMs int64)
| 259 | } |
| 260 | |
| 261 | func (h *histogram) removeStaleSeries(staleTimeMs int64) { |
| 262 | h.seriesMtx.Lock() |
| 263 | defer h.seriesMtx.Unlock() |
| 264 | |
| 265 | for hash, s := range h.series { |
| 266 | if s.lastUpdated.Load() < staleTimeMs { |
| 267 | delete(h.series, hash) |
| 268 | h.lifecycler.OnDelete(hash, h.activeSeriesPerHistogramSerie()) |
| 269 | } |
| 270 | } |
| 271 | h.seriesDemand.Advance() |
| 272 | } |
| 273 | |
| 274 | func (h *histogram) activeSeriesPerHistogramSerie() uint32 { |
| 275 | // sum + count + #buckets (including +Inf) |
nothing calls this directly
no test coverage detected