deepcrayon
/
lila
1
0
Fork 0
Code Releases Activity

change caffeine monitoring

pull/5761/head
Thibault Duplessis 2019-12-14 11:28:08 -06:00
parent b97ae44691
commit a9babeef3c
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/common/src/main/mon.scala
View File

@ -44,22 +44,22 @@ object mon {
}
def caffeineStats(cache: CaffeineCache[_, _], name: String): Unit = {
val stats = cache.stats
counter("caffeine.request").withTags(Map("name" -> name, "hit" -> true)).increment(stats.hitCount)
counter("caffeine.request").withTags(Map("name" -> name, "hit" -> false)).increment(stats.missCount)
gauge("caffeine.request").withTags(Map("name" -> name, "hit" -> true)).update(stats.hitCount)
gauge("caffeine.request").withTags(Map("name" -> name, "hit" -> false)).update(stats.missCount)
histogram("caffeine.hit.rate").withTag("name", name).record((stats.hitRate * 100000).toLong)
if (stats.totalLoadTime > 0) {
counter("caffeine.load.count")
gauge("caffeine.load.count")
.withTags(Map("name" -> name, "success" -> "success"))
.increment(stats.loadSuccessCount)
counter("caffeine.load.count")
.update(stats.loadSuccessCount)
gauge("caffeine.load.count")
.withTags(Map("name" -> name, "success" -> "failure"))
.increment(stats.loadFailureCount)
timer("caffeine.loadTime.cumulated")
.update(stats.loadFailureCount)
gauge("caffeine.loadTime.cumulated")
.withTag("name", name)
.record(stats.totalLoadTime / 1000000) // in millis; too much nanos for Kamon to handle)
.update(stats.totalLoadTime / 1000000) // in millis; too much nanos for Kamon to handle)
timer("caffeine.loadTime.penalty").withTag("name", name).record(stats.averageLoadPenalty.toLong)
}
counter("caffeine.eviction.count").withTag("name", name).increment(stats.evictionCount)
gauge("caffeine.eviction.count").withTag("name", name).update(stats.evictionCount)
gauge("caffeine.entry.count").withTag("name", name).update(cache.estimatedSize)
}
object evalCache {