diff options
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala')
| -rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala index 9898a6e8..c540ad69 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsdMetricsSender.scala @@ -43,6 +43,7 @@ class StatsdMetricsSender(statPrefix: String, remote: InetSocketAddress) extends object StatsdMetricsSender { sealed trait StatsdMetric + case class Counter(key: String, value: Long = 1, suffix: String = "c", samplingRate: Double = 1.0) extends StatsdMetric case class Timing(key: String, millis: Long, suffix: String = "ms", samplingRate: Double = 1.0) extends StatsdMetric case class Gauge(key: String, value: Long, suffix: String = "g", samplingRate: Double = 1.0) extends StatsdMetric @@ -63,8 +64,8 @@ object StatsdMetricsSender { */ private[this] def statFor(statPrefix: String, key: String, value: Long, suffix: String, samplingRate: Double): ByteString = { samplingRate match { - case x if x >= 1.0 ⇒ ByteString(s"${statPrefix}.${key}:${value}|$suffix") - case _ ⇒ ByteString(s"${statPrefix}.${key}:${value}|${suffix}|@$samplingRate") + case x if x >= 1.0 ⇒ ByteString(s"$statPrefix.$key:$value|$suffix") + case _ ⇒ ByteString(s"$statPrefix.$key:$value|$suffix|@$samplingRate") } } }
\ No newline at end of file |