aboutsummaryrefslogtreecommitdiff
path: root/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala')
-rw-r--r--kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala17
1 files changed, 17 insertions, 0 deletions
diff --git a/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala b/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala
index 22ce1f8e..8818ca3e 100644
--- a/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala
+++ b/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala
@@ -112,6 +112,16 @@ class DatadogMetricSenderSpec extends BaseKamonSpec("datadog-metric-sender-spec"
data.utf8String should be(s"kamon.category.metric-two:10|ms|@0.5|#category:datadog,my-cool-tag:some-value")
}
+ "not include the entity-category:entity:name identification tag for single instrument entities" in new UdpListenerFixture {
+ val (entity, testRecorder) = buildSimpleCounter("example-counter", tags = Map("my-cool-tag" -> "some-value"))
+ testRecorder.instrument.increment(17)
+
+ val udp = setup(Map(entity -> testRecorder.collect(collectionContext)))
+ val Udp.Send(data, _, _) = udp.expectMsgType[Udp.Send]
+
+ data.utf8String should be(s"kamon.counter.example-counter:17|c|#my-cool-tag:some-value")
+ }
+
}
trait UdpListenerFixture {
@@ -124,6 +134,13 @@ class DatadogMetricSenderSpec extends BaseKamonSpec("datadog-metric-sender-spec"
(entity, recorder)
}
+ def buildSimpleCounter(name: String, tags: Map[String, String] = Map.empty): (Entity, CounterRecorder) = {
+ val entity = Entity(name, SingleInstrumentEntityRecorder.Counter, tags)
+ val counter = Kamon.metrics.counter(name, tags)
+ val recorder = CounterRecorder(CounterKey("counter", UnitOfMeasurement.Unknown), counter)
+ (entity, recorder)
+ }
+
def setup(metrics: Map[Entity, EntitySnapshot]): TestProbe = {
val udp = TestProbe()
val metricsSender = system.actorOf(Props(new DatadogMetricsSender(new InetSocketAddress(localhostName, 0), testMaxPacketSize) {