blob: 5b4ceaf4cd87b109917a29b37941c2d6072b84b3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
package kamon.metric
import com.codahale.metrics._
object MetricsUtils {
def markMeter[T](meter:Meter)(f: => T): T = {
meter.mark()
f
}
//
// def incrementCounter(key: String) {
// counters.getOrElseUpdate(key, (metricsGroup.counter(s"${key}-counter"))).count
// }
//
// def markMeter(key: String) {
// meters.getOrElseUpdate(key, metricsGroup.meter(s"${key}-meter", "actor", "actor-message-counter", TimeUnit.SECONDS)).mark()
// }
//
// def trace[T](key: String)(f: => T): T = {
// val timer = timers.getOrElseUpdate(key, (metricsGroup.timer(s"${key}-timer")) )
// timer.time(f)
// }
// def markAndCountMeter[T](key: String)(f: => T): T = {
// markMeter(key)
// f
// }
//
// def traceAndCount[T](key: String)(f: => T): T = {
// incrementCounter(key)
// trace(key) {
// f
// }
//}
// implicit def runnable(f: () => Unit): Runnable =
// new Runnable() { def run() = f() }
//
//
// import java.util.concurrent.Callable
//
// implicit def callable[T](f: () => T): Callable[T] =
// new Callable[T]() { def call() = f() }
// private val actorCounter:Counter = new Counter
// private val actorTimer:Timer = new Timer
//
// metricsRegistry.register(s"counter-for-${actorName}", actorCounter)
// metricsRegistry.register(s"timer-for-${actorName}", actorTimer)
}
|
