Method removeStaleSeries

modules/generator/registry/counter.go:174–185

(staleTimeMs int64)

}

func (c *counter) removeStaleSeries(staleTimeMs int64) {
	c.seriesMtx.Lock()
	defer c.seriesMtx.Unlock()

	for hash, s := range c.series {
		if s.lastUpdated.Load() < staleTimeMs {
			delete(c.series, hash)
			c.lifecycler.OnDelete(hash, 1)
		}
	}
	c.seriesDemand.Advance()
}