scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

cache StatsD recalculate, invalidate, and threshold counts

Browse source
This commit is contained in:
Michael Baird 2017-05-16 15:21:26 -05:00
parent abc8a672ed
commit d4e9e5cdbc
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
cache.go
View file

@ -93,13 +93,15 @@ func (c *LRUCache) Get(id uint64) uint64 {
// Len returns the number of items in the cache.
func (c *LRUCache) Len() int { return c.cache.Len() }
// Invalidate is a no-op.
// Invalidate track size
func (c *LRUCache) Invalidate() {
c.stats.Count("cache.invalidate", 1, 1.0)
c.stats.Gauge("LRUCache", float64(c.cache.Len()), 1.0)
}
// Recalculate is a no-op.
// Recalculate track size
func (c *LRUCache) Recalculate() {
c.stats.Count("cache.recalculate", 1, 1.0)
c.stats.Gauge("LRUCache", float64(c.cache.Len()), 1.0)
}
@ -230,6 +232,7 @@ func (c *RankCache) Invalidate() {
func (c *RankCache) Recalculate() {
c.mu.Lock()
defer c.mu.Unlock()
c.stats.Count("cache.recalculate", 1, 1.0)
c.recalculate()
}
@ -239,6 +242,7 @@ func (c *RankCache) invalidate() {
if time.Now().Sub(c.updateTime).Seconds() < 10 {
return
}
c.stats.Count("cache.invalidate", 1, 1.0)
c.recalculate()
}
@ -270,6 +274,7 @@ func (c *RankCache) recalculate() {
// If size is larger than the threshold then trim it.
if len(c.entries) > c.thresholdBuffer {
c.stats.Count("cache.threshold", 1, 1.0)
for id, cnt := range c.entries {
if cnt <= c.thresholdValue {
delete(c.entries, id)