diff options
Diffstat (limited to 'kamon-annotation/src/test/scala/kamon/annotation/AnnotationInstrumentationSpec.scala')
| -rw-r--r-- | kamon-annotation/src/test/scala/kamon/annotation/AnnotationInstrumentationSpec.scala | 206 |
1 files changed, 206 insertions, 0 deletions
diff --git a/kamon-annotation/src/test/scala/kamon/annotation/AnnotationInstrumentationSpec.scala b/kamon-annotation/src/test/scala/kamon/annotation/AnnotationInstrumentationSpec.scala new file mode 100644 index 00000000..41f0fc34 --- /dev/null +++ b/kamon-annotation/src/test/scala/kamon/annotation/AnnotationInstrumentationSpec.scala @@ -0,0 +1,206 @@ +/* + * ========================================================================================= + * Copyright © 2013-2015 the kamon project <http://kamon.io/> + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the + * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, + * either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + * ========================================================================================= + */ + +package kamon.annotation + +import com.typesafe.config.ConfigFactory +import kamon.metric._ +import kamon.testkit.BaseKamonSpec + +class AnnotationInstrumentationSpec extends BaseKamonSpec("annotation-instrumentation-spec") { + import kamon.metric.TraceMetricsSpec.SegmentSyntax + + override lazy val config = + ConfigFactory.parseString( + """ + |kamon.metric { + | tick-interval = 1 hour + | default-collection-context-buffer-size = 100 + |} + """.stripMargin) + + "the Kamon Annotation module" should { + "create a new trace when is invoked a method annotated with @Trace" in { + for (id ← 1 to 10) Annotated(id).trace() + + val snapshot = takeSnapshotOf("trace", "trace") + snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(10) + snapshot.segments.size should be(0) + } + + "create a segment when is invoked a method annotated with @Segment" in { + for (id ← 1 to 10) Annotated().segment() + + val snapshot = takeSnapshotOf("trace-with-segment", "trace") + snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(10) + + snapshot.segments.size should be(1) + snapshot.segment("inner-segment", "inner", "segment") should not be empty + } + + "create a segment when is invoked a method annotated with @Segment and evaluate EL expressions" in { + for (id ← 1 to 10) Annotated(id).segmentWithEL() + + val snapshot = takeSnapshotOf("trace-with-segment-el", "trace") + snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(10) + + snapshot.segments.size should be(10) + snapshot.segment("inner-segment:1", "inner", "segment") should not be empty + } + + "count the invocations of a method annotated with @Count" in { + for (id ← 1 to 10) Annotated(id).count() + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.counter("count").get.count should be(10) + } + + "count the invocations of a method annotated with @Count and evaluate EL expressions" in { + for (id ← 1 to 2) Annotated(id).countWithEL() + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.counter("count:1").get.count should be(1) + snapshot.counter("count:2").get.count should be(1) + + val counterKey = (name: String) ⇒ (key: CounterKey) ⇒ key.name == name + + snapshot.counters.keys.find(counterKey("count:1")).get.metadata should be(Map("counter" -> "1", "env" -> "prod")) + snapshot.counters.keys.find(counterKey("count:2")).get.metadata should be(Map("counter" -> "1", "env" -> "prod")) + } + + "count the current invocations of a method annotated with @MinMaxCount" in { + for (id ← 1 to 10) { + Annotated(id).countMinMax() + } + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.minMaxCounter("minMax").get.max should be(1) + } + + "count the current invocations of a method annotated with @MinMaxCount and evaluate EL expressions" in { + for (id ← 1 to 10) Annotated(id).countMinMaxWithEL() + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.minMaxCounter("minMax:1").get.sum should be(1) + snapshot.minMaxCounter("minMax:2").get.sum should be(1) + + val minMaxKey = (name: String) ⇒ (key: MinMaxCounterKey) ⇒ key.name == name + + snapshot.minMaxCounters.keys.find(minMaxKey("minMax:1")).get.metadata should be(Map("minMax" -> "1", "env" -> "dev")) + snapshot.minMaxCounters.keys.find(minMaxKey("minMax:2")).get.metadata should be(Map("minMax" -> "1", "env" -> "dev")) + } + + "measure the time spent in the execution of a method annotated with @Time" in { + for (id ← 1 to 1) Annotated(id).time() + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.histogram("time").get.numberOfMeasurements should be(1) + } + + "measure the time spent in the execution of a method annotated with @Time and evaluate EL expressions" in { + for (id ← 1 to 1) Annotated(id).timeWithEL() + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.histogram("time:1").get.numberOfMeasurements should be(1) + + val histogramKey = (name: String) ⇒ (key: HistogramKey) ⇒ key.name == name + + snapshot.histograms.keys.find(histogramKey("time:1")).get.metadata should be(Map("slow-service" -> "service", "env" -> "prod")) + } + + "record the value returned by a method annotated with @Histogram" in { + for (value ← 1 to 5) Annotated().histogram(value) + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.histogram("histogram").get.numberOfMeasurements should be(5) + snapshot.histogram("histogram").get.min should be(1) + snapshot.histogram("histogram").get.max should be(5) + snapshot.histogram("histogram").get.sum should be(15) + } + + "record the value returned by a method annotated with @Histogram and evaluate EL expressions" in { + for (value ← 1 to 2) Annotated(value).histogramWithEL(value) + + val snapshot = takeSnapshotOf("simple-metric", "simple-metric") + snapshot.histogram("histogram:1").get.numberOfMeasurements should be(1) + snapshot.histogram("histogram:1").get.min should be(1) + snapshot.histogram("histogram:1").get.max should be(1) + snapshot.histogram("histogram:1").get.sum should be(1) + + snapshot.histogram("histogram:2").get.numberOfMeasurements should be(1) + snapshot.histogram("histogram:2").get.min should be(2) + snapshot.histogram("histogram:2").get.max should be(2) + snapshot.histogram("histogram:2").get.sum should be(2) + + val histogramKey = (name: String) ⇒ (key: HistogramKey) ⇒ key.name == name + + snapshot.histograms.keys.find(histogramKey("histogram:1")).get.metadata should be(Map("histogram" -> "hdr", "env" -> "prod")) + snapshot.histograms.keys.find(histogramKey("histogram:2")).get.metadata should be(Map("histogram" -> "hdr", "env" -> "prod")) + } + + } +} + +@EnableKamon +case class Annotated(id: Long) { + + @Trace("trace") + def trace(): Unit = {} + + @Trace("trace-with-segment") + def segment(): Unit = { + inner() // method annotated with @Segment + } + + @Trace("trace-with-segment-el") + def segmentWithEL(): Unit = { + innerWithEL() // method annotated with @Segment + } + + @Count(name = "count") + def count(): Unit = {} + + @Count(name = "${'count:' += this.id}", tags = "${'counter':'1', 'env':'prod'}") + def countWithEL(): Unit = {} + + @MinMaxCount(name = "minMax") + def countMinMax(): Unit = {} + + @MinMaxCount(name = "#{'minMax:' += this.id}", tags = "#{'minMax':'1', 'env':'dev'}") + def countMinMaxWithEL(): Unit = {} + + @Time(name = "time") + def time(): Unit = {} + + @Time(name = "${'time:' += this.id}", tags = "${'slow-service':'service', 'env':'prod'}") + def timeWithEL(): Unit = {} + + @Histogram(name = "histogram") + def histogram(value: Long): Long = value + + @Histogram(name = "#{'histogram:' += this.id}", tags = "${'histogram':'hdr', 'env':'prod'}") + def histogramWithEL(value: Long): Long = value + + @Segment(name = "inner-segment", category = "inner", library = "segment") + private def inner(): Unit = {} + + @Segment(name = "#{'inner-segment:' += this.id}", category = "inner", library = "segment") + private def innerWithEL(): Unit = {} +} + +object Annotated { + def apply(): Annotated = new Annotated(0L) +}
\ No newline at end of file |