|
1 | 1 | package com.twitter.finagle.metrics
|
2 | 2 |
|
3 | 3 | import com.codahale.metrics.{Gauge => MGauge, Metric, MetricFilter, MetricRegistry}
|
4 |
| -import com.twitter.finagle.stats.{Counter, Gauge, Stat, StatsReceiver} |
| 4 | +import com.twitter.finagle.stats.{Counter, Gauge, Verbosity, Stat, StatsReceiver} |
5 | 5 | import scala.collection.JavaConverters._
|
6 | 6 |
|
7 | 7 | object MetricsStatsReceiver {
|
8 | 8 | val metrics: MetricRegistry = new MetricRegistry
|
9 | 9 |
|
10 | 10 | private[metrics] case class MetricCounter(name: String) extends Counter {
|
11 | 11 | private val meter = metrics.meter(name)
|
12 |
| - override def incr(delta: Int): Unit = meter.mark(delta) |
| 12 | + override def incr(delta: Long): Unit = meter.mark(delta) |
13 | 13 | }
|
14 | 14 |
|
15 | 15 | private[metrics] case class MetricGauge(name: String)(f: => Float) extends Gauge {
|
@@ -44,12 +44,12 @@ class MetricsStatsReceiver extends StatsReceiver {
|
44 | 44 | private[this] def format(names: Seq[String]) =
|
45 | 45 | names.mkString(".")
|
46 | 46 |
|
47 |
| - override def counter(names: String*): Counter = |
| 47 | + override def counter(verbosity: Verbosity, names: String*): Counter = |
48 | 48 | MetricsStatsReceiver.MetricCounter(format(names))
|
49 | 49 |
|
50 |
| - override def addGauge(names: String*)(f: => Float): Gauge = |
| 50 | + override def addGauge(verbosity: Verbosity, names: String*)(f: => Float): Gauge = |
51 | 51 | MetricsStatsReceiver.MetricGauge(format(names)) (f)
|
52 | 52 |
|
53 |
| - override def stat(names: String*): Stat = |
| 53 | + override def stat(verbosity: Verbosity, names: String*): Stat = |
54 | 54 | MetricsStatsReceiver.MetricStat(format(names))
|
55 | 55 | }
|
0 commit comments