(staleTimeMs int64)
| 151 | } |
| 152 | |
| 153 | func (g *gauge) removeStaleSeries(staleTimeMs int64) { |
| 154 | g.seriesMtx.Lock() |
| 155 | defer g.seriesMtx.Unlock() |
| 156 | |
| 157 | for hash, s := range g.series { |
| 158 | if s.lastUpdated.Load() < staleTimeMs { |
| 159 | delete(g.series, hash) |
| 160 | g.lifecycler.OnDelete(hash, 1) |
| 161 | } |
| 162 | } |
| 163 | g.seriesDemand.Advance() |
| 164 | } |