diff options
Diffstat (limited to 'kamon-core/src/legacy-test/scala/kamon/metric')
10 files changed, 0 insertions, 1129 deletions
diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/MetricScaleDecoratorSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/MetricScaleDecoratorSpec.scala deleted file mode 100644 index d3d0f4fb..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/MetricScaleDecoratorSpec.scala +++ /dev/null @@ -1,102 +0,0 @@ -/* - * ========================================================================================= - * 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.metric - -import kamon.Kamon -import kamon.metric.SubscriptionsDispatcher.TickMetricSnapshot -import kamon.metric.instrument.{InstrumentFactory, Memory, Time, UnitOfMeasurement} -import kamon.testkit.BaseKamonSpec -import kamon.util.MilliTimestamp -import org.scalatest.OptionValues._ - -class MetricScaleDecoratorSpec extends BaseKamonSpec("metrics-scale-decorator-spec") with SnapshotFixtures { - "the MetricScaleDecorator" when { - "receives a snapshot" which { - - val scaleDecorator = system.actorOf(MetricScaleDecorator.props( - Some(Time.Milliseconds), Some(Memory.KiloBytes), testActor - )) - "is empty" should { - "do nothing for empty snapshots" in { - scaleDecorator ! emptySnapshot - expectMsg(emptySnapshot) - } - } - "is non empty" should { - scaleDecorator ! nonEmptySnapshot - val scaled = expectMsgType[TickMetricSnapshot] - val snapshot = scaled.metrics(testEntity) - - "scale time metrics" in { - snapshot.histogram("nano-time").value.max should be(10L +- 1L) - snapshot.counter("micro-time").value.count should be(1000L) - } - "scale memory metrics" in { - snapshot.histogram("byte-memory").value.max should be(1) - snapshot.counter("kbyte-memory").value.count should be(100L) - } - "do nothing with unknown metrics" in { - snapshot.histogram("unknown-histogram").value.max should be(1000L) - snapshot.counter("unknown-counter").value.count should be(10L) - } - "not change from and to" in { - scaled.from.millis should be(1000) - scaled.to.millis should be(2000) - } - } - } - } -} - -trait SnapshotFixtures { - self: BaseKamonSpec ⇒ - - class ScaleDecoratorTestMetrics(instrumentFactory: InstrumentFactory) - extends GenericEntityRecorder(instrumentFactory) { - val nanoTime = histogram("nano-time", Time.Nanoseconds) - val microTime = counter("micro-time", Time.Microseconds) - val byteMemory = histogram("byte-memory", Memory.Bytes) - val kbyteMemory = counter("kbyte-memory", Memory.KiloBytes) - val unknownHistogram = histogram("unknown-histogram", UnitOfMeasurement.Unknown) - val unknownCounter = counter("unknown-counter", UnitOfMeasurement.Unknown) - } - - object ScaleDecoratorTestMetrics extends EntityRecorderFactory[ScaleDecoratorTestMetrics] { - override def category: String = "decorator-spec" - - override def createRecorder(instrumentFactory: InstrumentFactory): ScaleDecoratorTestMetrics = - new ScaleDecoratorTestMetrics(instrumentFactory) - } - - val testEntity = Entity("metrics-scale-decorator-spec", "decorator-spec") - val recorder = Kamon.metrics.entity(ScaleDecoratorTestMetrics, "metrics-scale-decorator-spec") - - val emptySnapshot = TickMetricSnapshot(new MilliTimestamp(1000), new MilliTimestamp(2000), Map.empty) - - recorder.unknownCounter.increment(10) - recorder.unknownHistogram.record(1000L) - recorder.nanoTime.record(10000000L) - recorder.microTime.increment(1000000L) - recorder.byteMemory.record(1024L) - recorder.kbyteMemory.increment(100L) - - val nonEmptySnapshot = TickMetricSnapshot(new MilliTimestamp(1000), new MilliTimestamp(2000), Map( - (testEntity → recorder.collect(collectionContext)) - )) - -} - diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/SimpleMetricsSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/SimpleMetricsSpec.scala deleted file mode 100644 index 6d753888..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/SimpleMetricsSpec.scala +++ /dev/null @@ -1,106 +0,0 @@ -/* - * ========================================================================================= - * 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.metric - -import kamon.Kamon -import kamon.metric.instrument.Histogram.DynamicRange -import kamon.testkit.BaseKamonSpec -import scala.concurrent.duration._ - -class SimpleMetricsSpec extends BaseKamonSpec("simple-metrics-spec") { - - "the SimpleMetrics extension" should { - - "allow registering a fully configured Histogram and get the same Histogram if registering again" in { - val histogramA = Kamon.metrics.histogram("histogram-with-settings", DynamicRange(1, 10000, 2)) - val histogramB = Kamon.metrics.histogram("histogram-with-settings", DynamicRange(1, 10000, 2)) - - histogramA shouldBe theSameInstanceAs(histogramB) - } - - "return the original Histogram when registering a fully configured Histogram for second time but with different settings" in { - val histogramA = Kamon.metrics.histogram("histogram-with-settings", DynamicRange(1, 10000, 2)) - val histogramB = Kamon.metrics.histogram("histogram-with-settings", DynamicRange(1, 50000, 2)) - - histogramA shouldBe theSameInstanceAs(histogramB) - } - - "allow registering a Histogram that takes the default configuration from the kamon.metrics.precision settings" in { - Kamon.metrics.histogram("histogram-with-default-configuration") - } - - "allow registering a Counter and get the same Counter if registering again" in { - val counterA = Kamon.metrics.counter("counter") - val counterB = Kamon.metrics.counter("counter") - - counterA shouldBe theSameInstanceAs(counterB) - } - - "allow registering a fully configured MinMaxCounter and get the same MinMaxCounter if registering again" in { - val minMaxCounterA = Kamon.metrics.minMaxCounter("min-max-counter-with-settings", DynamicRange(1, 10000, 2), 1 second) - val minMaxCounterB = Kamon.metrics.minMaxCounter("min-max-counter-with-settings", DynamicRange(1, 10000, 2), 1 second) - - minMaxCounterA shouldBe theSameInstanceAs(minMaxCounterB) - } - - "return the original MinMaxCounter when registering a fully configured MinMaxCounter for second time but with different settings" in { - val minMaxCounterA = Kamon.metrics.minMaxCounter("min-max-counter-with-settings", DynamicRange(1, 10000, 2), 1 second) - val minMaxCounterB = Kamon.metrics.minMaxCounter("min-max-counter-with-settings", DynamicRange(1, 50000, 2), 1 second) - - minMaxCounterA shouldBe theSameInstanceAs(minMaxCounterB) - } - - "allow registering a MinMaxCounter that takes the default configuration from the kamon.metrics.precision settings" in { - Kamon.metrics.minMaxCounter("min-max-counter-with-default-configuration") - } - - "allow registering a fully configured Gauge and get the same Gauge if registering again" in { - val gaugeA = Kamon.metrics.gauge("gauge-with-settings", DynamicRange(1, 10000, 2), 1 second)(1L) - val gaugeB = Kamon.metrics.gauge("gauge-with-settings", DynamicRange(1, 10000, 2), 1 second)(1L) - - gaugeA shouldBe theSameInstanceAs(gaugeB) - } - - "return the original Gauge when registering a fully configured Gauge for second time but with different settings" in { - val gaugeA = Kamon.metrics.gauge("gauge-with-settings", DynamicRange(1, 10000, 2), 1 second)(1L) - val gaugeB = Kamon.metrics.gauge("gauge-with-settings", DynamicRange(1, 10000, 2), 1 second)(1L) - - gaugeA shouldBe theSameInstanceAs(gaugeB) - } - - "allow registering a Gauge that takes the default configuration from the kamon.metrics.precision settings" in { - Kamon.metrics.gauge("gauge-with-default-configuration")(2L) - } - - "allow un-registering user metrics" in { - val counter = Kamon.metrics.counter("counter-for-remove") - val histogram = Kamon.metrics.histogram("histogram-for-remove") - val minMaxCounter = Kamon.metrics.minMaxCounter("min-max-counter-for-remove") - val gauge = Kamon.metrics.gauge("gauge-for-remove")(2L) - - Kamon.metrics.removeCounter("counter-for-remove") - Kamon.metrics.removeHistogram("histogram-for-remove") - Kamon.metrics.removeMinMaxCounter("min-max-counter-for-remove") - Kamon.metrics.removeGauge("gauge-for-remove") - - counter should not be (theSameInstanceAs(Kamon.metrics.counter("counter-for-remove"))) - histogram should not be (theSameInstanceAs(Kamon.metrics.histogram("histogram-for-remove"))) - minMaxCounter should not be (theSameInstanceAs(Kamon.metrics.minMaxCounter("min-max-counter-for-remove"))) - gauge should not be (theSameInstanceAs(Kamon.metrics.gauge("gauge-for-remove")(2L))) - } - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/SubscriptionsProtocolSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/SubscriptionsProtocolSpec.scala deleted file mode 100644 index ee34acc7..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/SubscriptionsProtocolSpec.scala +++ /dev/null @@ -1,150 +0,0 @@ -/* - * ========================================================================================= - * 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.metric - -import akka.actor._ -import akka.testkit.{TestProbe, ImplicitSender} -import com.typesafe.config.ConfigFactory -import kamon.Kamon -import kamon.metric.SubscriptionsDispatcher.TickMetricSnapshot -import kamon.testkit.BaseKamonSpec -import scala.concurrent.duration._ - -class SubscriptionsProtocolSpec extends BaseKamonSpec("subscriptions-protocol-spec") with ImplicitSender { - override lazy val config = - ConfigFactory.parseString( - """ - |kamon.metric { - | tick-interval = 1 hour - |} - """.stripMargin - ) - - lazy val metricsModule = Kamon.metrics - import metricsModule.{entity, subscribe, unsubscribe} - val defaultTags: Map[String, String] = Kamon.metrics.defaultTags - - "the Subscriptions messaging protocol" should { - "allow subscribing for a single tick" in { - val subscriber = TestProbe() - entity(TraceMetrics, "one-shot") - subscribe("trace", "one-shot", subscriber.ref, permanently = false) - - flushSubscriptions() - val tickSnapshot = subscriber.expectMsgType[TickMetricSnapshot] - - tickSnapshot.metrics.size should be(1) - tickSnapshot.metrics.keys should contain(Entity("one-shot", "trace", defaultTags)) - - flushSubscriptions() - subscriber.expectNoMsg(1 second) - } - - "subscriptions should include default tags" in { - val subscriber = TestProbe() - - Kamon.metrics.histogram("histogram-with-tags").record(1) - Kamon.metrics.subscribe("**", "**", subscriber.ref, permanently = true) - flushSubscriptions() - - val tickSubscription = subscriber.expectMsgType[TickMetricSnapshot] - tickSubscription.metrics.head._1.tags.get("name") shouldBe Some("jason") - tickSubscription.metrics.head._1.tags.get("number") shouldBe Some("42") - tickSubscription.metrics.head._1.tags.get("username").isDefined shouldBe true - tickSubscription.metrics.head._1.tags.get("object.nested-bool") shouldBe Some("true") - tickSubscription.metrics.head._1.tags.get("object.nested-string") shouldBe Some("a string") - tickSubscription.metrics.head._1.tags.get("list") shouldBe None - } - - "allow subscribing permanently to a metric" in { - val subscriber = TestProbe() - entity(TraceMetrics, "permanent") - subscribe("trace", "permanent", subscriber.ref, permanently = true) - - for (repetition ← 1 to 5) { - flushSubscriptions() - val tickSnapshot = subscriber.expectMsgType[TickMetricSnapshot] - - tickSnapshot.metrics.size should be(1) - tickSnapshot.metrics.keys should contain(Entity("permanent", "trace", defaultTags)) - } - } - - "allow subscribing to metrics matching a glob pattern" in { - val subscriber = TestProbe() - entity(TraceMetrics, "include-one") - entity(TraceMetrics, "exclude-two") - entity(TraceMetrics, "include-three") - subscribe("trace", "include-*", subscriber.ref, permanently = true) - - for (repetition ← 1 to 5) { - flushSubscriptions() - val tickSnapshot = subscriber.expectMsgType[TickMetricSnapshot] - - tickSnapshot.metrics.size should be(2) - tickSnapshot.metrics.keys should contain(Entity("include-one", "trace", defaultTags)) - tickSnapshot.metrics.keys should contain(Entity("include-three", "trace", defaultTags)) - } - } - - "send a single TickMetricSnapshot to each subscriber, even if subscribed multiple times" in { - val subscriber = TestProbe() - entity(TraceMetrics, "include-one") - entity(TraceMetrics, "exclude-two") - entity(TraceMetrics, "include-three") - subscribe("trace", "include-one", subscriber.ref, permanently = true) - subscribe("trace", "include-three", subscriber.ref, permanently = true) - - for (repetition ← 1 to 5) { - flushSubscriptions() - val tickSnapshot = subscriber.expectMsgType[TickMetricSnapshot] - - tickSnapshot.metrics.size should be(2) - tickSnapshot.metrics.keys should contain(Entity("include-one", "trace", defaultTags)) - tickSnapshot.metrics.keys should contain(Entity("include-three", "trace", defaultTags)) - } - } - - "allow un-subscribing a subscriber" in { - val subscriber = TestProbe() - entity(TraceMetrics, "one-shot") - subscribe("trace", "one-shot", subscriber.ref, permanently = true) - - flushSubscriptions() - val tickSnapshot = subscriber.expectMsgType[TickMetricSnapshot] - tickSnapshot.metrics.size should be(1) - tickSnapshot.metrics.keys should contain(Entity("one-shot", "trace", defaultTags)) - - unsubscribe(subscriber.ref) - - flushSubscriptions() - subscriber.expectNoMsg(1 second) - } - } - - def subscriptionsActor: ActorRef = { - val listener = TestProbe() - system.actorSelection("/user/kamon/kamon-metrics").tell(Identify(1), listener.ref) - listener.expectMsgType[ActorIdentity].ref.get - } -} - -class ForwarderSubscriber(target: ActorRef) extends Actor { - def receive = { - case anything ⇒ target.forward(anything) - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/TickMetricSnapshotBufferSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/TickMetricSnapshotBufferSpec.scala deleted file mode 100644 index 6172a9e0..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/TickMetricSnapshotBufferSpec.scala +++ /dev/null @@ -1,97 +0,0 @@ -/* - * ========================================================================================= - * Copyright © 2013 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.metric - -import com.typesafe.config.ConfigFactory -import kamon.Kamon -import kamon.metric.instrument.Histogram.MutableRecord -import kamon.testkit.BaseKamonSpec -import kamon.util.MilliTimestamp -import akka.testkit.ImplicitSender -import scala.concurrent.duration._ -import kamon.metric.SubscriptionsDispatcher.TickMetricSnapshot - -class TickMetricSnapshotBufferSpec extends BaseKamonSpec("trace-metrics-spec") with ImplicitSender { - - "the TickMetricSnapshotBuffer" should { - "merge TickMetricSnapshots received until the flush timeout is reached and fix the from/to fields" in new SnapshotFixtures { - val buffer = system.actorOf(TickMetricSnapshotBuffer.props(3 seconds, testActor)) - - buffer ! firstEmpty - buffer ! secondEmpty - buffer ! thirdEmpty - - within(2 seconds)(expectNoMsg()) - val mergedSnapshot = expectMsgType[TickMetricSnapshot] - - mergedSnapshot.from.millis should equal(1000) - mergedSnapshot.to.millis should equal(4000) - mergedSnapshot.metrics should be('empty) - } - - "merge empty and non-empty snapshots" in new SnapshotFixtures { - val buffer = system.actorOf(TickMetricSnapshotBuffer.props(3 seconds, testActor)) - - buffer ! firstNonEmpty - buffer ! secondNonEmpty - buffer ! thirdEmpty - - within(2 seconds)(expectNoMsg()) - val mergedSnapshot = expectMsgType[TickMetricSnapshot] - - mergedSnapshot.from.millis should equal(1000) - mergedSnapshot.to.millis should equal(4000) - mergedSnapshot.metrics should not be ('empty) - - val testMetricSnapshot = mergedSnapshot.metrics(testTraceIdentity).histogram("elapsed-time").get - testMetricSnapshot.min should equal(10) - testMetricSnapshot.max should equal(300) - testMetricSnapshot.numberOfMeasurements should equal(6) - testMetricSnapshot.recordsIterator.toStream should contain allOf ( - MutableRecord(10, 3), - MutableRecord(20, 1), - MutableRecord(30, 1), - MutableRecord(300, 1) - ) - - } - } - - trait SnapshotFixtures { - val collectionContext = Kamon.metrics.buildDefaultCollectionContext - val testTraceIdentity = Entity("buffer-spec-test-trace", "trace") - val traceRecorder = Kamon.metrics.entity(TraceMetrics, "buffer-spec-test-trace") - - val firstEmpty = TickMetricSnapshot(new MilliTimestamp(1000), new MilliTimestamp(2000), Map.empty) - val secondEmpty = TickMetricSnapshot(new MilliTimestamp(2000), new MilliTimestamp(3000), Map.empty) - val thirdEmpty = TickMetricSnapshot(new MilliTimestamp(3000), new MilliTimestamp(4000), Map.empty) - - traceRecorder.elapsedTime.record(10L) - traceRecorder.elapsedTime.record(20L) - traceRecorder.elapsedTime.record(30L) - val firstNonEmpty = TickMetricSnapshot(new MilliTimestamp(1000), new MilliTimestamp(2000), Map( - (testTraceIdentity → traceRecorder.collect(collectionContext)) - )) - - traceRecorder.elapsedTime.record(10L) - traceRecorder.elapsedTime.record(10L) - traceRecorder.elapsedTime.record(300L) - val secondNonEmpty = TickMetricSnapshot(new MilliTimestamp(1000), new MilliTimestamp(2000), Map( - (testTraceIdentity → traceRecorder.collect(collectionContext)) - )) - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/TraceMetricsSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/TraceMetricsSpec.scala deleted file mode 100644 index 4c44dc07..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/TraceMetricsSpec.scala +++ /dev/null @@ -1,121 +0,0 @@ -/* - * ========================================================================================= - * Copyright © 2013-2016 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.metric - -import akka.testkit.ImplicitSender -import com.typesafe.config.ConfigFactory -import kamon.testkit.BaseKamonSpec -import kamon.trace.Tracer -import kamon.metric.instrument.Histogram - -import scala.util.control.NoStackTrace - -class TraceMetricsSpec extends BaseKamonSpec("trace-metrics-spec") with ImplicitSender { - - "the TraceMetrics" should { - "record the elapsed time between a trace creation and finish" in { - for (repetitions ← 1 to 10) { - Tracer.withContext(newContext("record-elapsed-time")) { - Tracer.currentContext.finish() - } - } - - val snapshot = takeSnapshotOf("record-elapsed-time", "trace") - snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(10) - } - - "record the elapsed time for segments that occur inside a given trace" in { - Tracer.withContext(newContext("trace-with-segments")) { - val segment = Tracer.currentContext.startSegment("test-segment", "test-category", "test-library") - segment.finish() - Tracer.currentContext.finish() - } - - val snapshot = takeSnapshotOf("test-segment", "trace-segment", - tags = Map( - "trace" → "trace-with-segments", - "category" → "test-category", - "library" → "test-library" - )) - - snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(1) - } - - "record the elapsed time for segments that finish after their correspondent trace has finished" in { - val segment = Tracer.withContext(newContext("closing-segment-after-trace")) { - val s = Tracer.currentContext.startSegment("test-segment", "test-category", "test-library") - Tracer.currentContext.finish() - s - } - - val beforeFinishSegmentSnapshot = takeSnapshotOf("closing-segment-after-trace", "trace") - beforeFinishSegmentSnapshot.histogram("elapsed-time").get.numberOfMeasurements should be(1) - - intercept[NoSuchElementException] { - // The segment metric should not exist before we it has finished. - - takeSnapshotOf("test-segment", "trace-segment", - tags = Map( - "trace" → "closing-segment-after-trace", - "category" → "test-category", - "library" → "test-library" - )) - } - - segment.finish() - - val afterFinishSegmentSnapshot = takeSnapshotOf("test-segment", "trace-segment", - tags = Map( - "trace" → "closing-segment-after-trace", - "category" → "test-category", - "library" → "test-library" - )) - - afterFinishSegmentSnapshot.histogram("elapsed-time").get.numberOfMeasurements should be(1) - } - - "record the elapsed time between a trace creation and finish with an error" in { - for (repetitions ← 1 to 10) { - Tracer.withContext(newContext("record-elapsed-time-with-error")) { - Tracer.currentContext.finishWithError(new RuntimeException("awesome-trace-error") with NoStackTrace) - } - } - - val snapshot = takeSnapshotOf("record-elapsed-time-with-error", "trace") - snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(10) - snapshot.counter("errors").get.count should be(10) - } - - "record the elapsed time for segments that finish with an error and that occur inside a given trace" in { - Tracer.withContext(newContext("trace-with-segments")) { - val segment = Tracer.currentContext.startSegment("test-segment-with-error", "test-category", "test-library") - segment.finishWithError(new RuntimeException("awesome-segment-error") with NoStackTrace) - Tracer.currentContext.finish() - } - - val snapshot = takeSnapshotOf("test-segment-with-error", "trace-segment", - tags = Map( - "trace" → "trace-with-segments", - "category" → "test-category", - "library" → "test-library" - )) - - snapshot.histogram("elapsed-time").get.numberOfMeasurements should be(1) - snapshot.counter("errors").get.count should be(1) - } - } -}
\ No newline at end of file diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/CounterSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/instrument/CounterSpec.scala deleted file mode 100644 index d5d651e5..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/CounterSpec.scala +++ /dev/null @@ -1,79 +0,0 @@ -/* - * ========================================================================================= - * 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.metric.instrument - -import java.nio.LongBuffer - -import org.scalatest.{Matchers, WordSpec} - -class CounterSpec extends WordSpec with Matchers { - - "a Counter" should { - "allow increment only operations" in new CounterFixture { - counter.increment() - counter.increment(10) - - intercept[UnsupportedOperationException] { - counter.increment(-10) - } - } - - "reset to zero when a snapshot is taken" in new CounterFixture { - counter.increment(100) - takeSnapshotFrom(counter).count should be(100) - takeSnapshotFrom(counter).count should be(0) - takeSnapshotFrom(counter).count should be(0) - - counter.increment(50) - takeSnapshotFrom(counter).count should be(50) - takeSnapshotFrom(counter).count should be(0) - } - - "produce a snapshot that can be merged with others" in new CounterFixture { - val counterA = Counter() - val counterB = Counter() - counterA.increment(100) - counterB.increment(200) - - val counterASnapshot = takeSnapshotFrom(counterA) - val counterBSnapshot = takeSnapshotFrom(counterB) - - counterASnapshot.merge(counterBSnapshot, collectionContext).count should be(300) - counterBSnapshot.merge(counterASnapshot, collectionContext).count should be(300) - } - - "produce a snapshot that can be scaled" in new CounterFixture { - counter.increment(100) - - val counterSnapshot = takeSnapshotFrom(counter) - - val scaledSnapshot = counterSnapshot.scale(Time.Milliseconds, Time.Microseconds) - scaledSnapshot.count should be(100000) - } - - } - - trait CounterFixture { - val counter = Counter() - - val collectionContext = new CollectionContext { - val buffer: LongBuffer = LongBuffer.allocate(1) - } - - def takeSnapshotFrom(counter: Counter): Counter.Snapshot = counter.collect(collectionContext) - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/GaugeSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/instrument/GaugeSpec.scala deleted file mode 100644 index ec07d66c..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/GaugeSpec.scala +++ /dev/null @@ -1,79 +0,0 @@ -/* - * ========================================================================================= - * 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.metric.instrument - -import java.util.concurrent.atomic.AtomicLong -import kamon.Kamon -import kamon.metric.instrument.Histogram.DynamicRange -import kamon.testkit.BaseKamonSpec -import scala.concurrent.duration._ - -class GaugeSpec extends BaseKamonSpec("gauge-spec") { - - "a Gauge" should { - "automatically record the current value using the configured refresh-interval" in new GaugeFixture { - val (numberOfValuesRecorded, gauge) = createGauge() - Thread.sleep(1.second.toMillis) - - numberOfValuesRecorded.get() should be(10L +- 1L) - gauge.cleanup - } - - "stop automatically recording after a call to cleanup" in new GaugeFixture { - val (numberOfValuesRecorded, gauge) = createGauge() - Thread.sleep(1.second.toMillis) - - gauge.cleanup - numberOfValuesRecorded.get() should be(10L +- 1L) - Thread.sleep(1.second.toMillis) - - numberOfValuesRecorded.get() should be(10L +- 1L) - } - - "produce a Histogram snapshot including all the recorded values" in new GaugeFixture { - val (numberOfValuesRecorded, gauge) = createGauge() - - Thread.sleep(1.second.toMillis) - gauge.cleanup - val snapshot = gauge.collect(Kamon.metrics.buildDefaultCollectionContext) - - snapshot.numberOfMeasurements should be(10L +- 1L) - snapshot.min should be(1) - snapshot.max should be(10L +- 1L) - } - - "not record the current value when doing a collection" in new GaugeFixture { - val (numberOfValuesRecorded, gauge) = createGauge(10 seconds) - - val snapshot = gauge.collect(Kamon.metrics.buildDefaultCollectionContext) - snapshot.numberOfMeasurements should be(0) - numberOfValuesRecorded.get() should be(0) - } - } - - trait GaugeFixture { - def createGauge(refreshInterval: FiniteDuration = 100 millis): (AtomicLong, Gauge) = { - val recordedValuesCounter = new AtomicLong(0) - val gauge = Gauge(DynamicRange(1, 100, 2), refreshInterval, Kamon.metrics.settings.refreshScheduler, { - () ⇒ recordedValuesCounter.addAndGet(1) - }) - - (recordedValuesCounter, gauge) - } - - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/HistogramSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/instrument/HistogramSpec.scala deleted file mode 100644 index 9551c6ea..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/HistogramSpec.scala +++ /dev/null @@ -1,157 +0,0 @@ -/* - * ========================================================================================= - * Copyright © 2013 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.metric.instrument - -import java.nio.LongBuffer - -import kamon.metric.instrument.Histogram.DynamicRange -import org.scalatest.{Matchers, WordSpec} - -import scala.util.Random - -class HistogramSpec extends WordSpec with Matchers { - - "a Histogram" should { - "allow record values within the configured range" in new HistogramFixture { - histogram.record(1000) - histogram.record(5000, count = 100) - histogram.record(10000) - } - - "not fail when recording values higher than the highest trackable value" in new HistogramFixture { - histogram.record(Long.MaxValue) - } - - "reset all recorded levels to zero after a snapshot collection" in new HistogramFixture { - histogram.record(100) - histogram.record(200) - histogram.record(300) - - takeSnapshot().numberOfMeasurements should be(3) - takeSnapshot().numberOfMeasurements should be(0) - } - - "produce a snapshot" which { - "supports min, max, percentile, sum, numberOfMeasurements and recordsIterator operations" in new HistogramFixture { - histogram.record(100) - histogram.record(200, count = 200) - histogram.record(300) - histogram.record(900) - - val snapshot = takeSnapshot() - - snapshot.min should equal(100L +- 1L) - snapshot.max should equal(900L +- 9L) - snapshot.percentile(50.0D) should be(200) - snapshot.percentile(99.5D) should be(300) - snapshot.percentile(99.9D) should be(900) - snapshot.sum should be(41300) - snapshot.numberOfMeasurements should be(203) - - val records = snapshot.recordsIterator.map(r ⇒ r.level → r.count).toSeq - records.size should be(4) - records(0) should be(100 → 1) - records(1) should be(200 → 200) - records(2) should be(300 → 1) - records(3) should be(900 → 1) - } - - "can be scaled" in new HistogramFixture { - histogram.record(100) - histogram.record(200, count = 200) - histogram.record(300) - histogram.record(900) - - val snapshot = takeSnapshot().scale(Time.Seconds, Time.Milliseconds) - - snapshot.min should equal(100000L +- 1000L) - snapshot.max should equal(900000L +- 9000L) - snapshot.percentile(50.0D) should be(200000) - snapshot.percentile(99.5D) should be(300000) - snapshot.percentile(99.9D) should be(900000) - snapshot.sum should be(41300000) - snapshot.numberOfMeasurements should be(203) - - val records = snapshot.recordsIterator.map(r ⇒ r.level → r.count).toSeq - records.size should be(4) - records(0) should be(100000 → 1) - records(1) should be(200000 → 200) - records(2) should be(300000 → 1) - records(3) should be(900000 → 1) - } - - "can be merged with another snapshot" in new MultipleHistogramFixture { - val random = new Random(System.nanoTime()) - - for (repetitions ← 1 to 1000) { - // Put some values on A and Control - for (_ ← 1 to 1000) { - val newRecording = random.nextInt(100000) - controlHistogram.record(newRecording) - histogramA.record(newRecording) - } - - // Put some values on B and Control - for (_ ← 1 to 2000) { - val newRecording = random.nextInt(100000) - controlHistogram.record(newRecording) - histogramB.record(newRecording) - } - - val controlSnapshot = takeSnapshotFrom(controlHistogram) - val histogramASnapshot = takeSnapshotFrom(histogramA) - val histogramBSnapshot = takeSnapshotFrom(histogramB) - - assertEquals(controlSnapshot, histogramASnapshot.merge(histogramBSnapshot, collectionContext)) - assertEquals(controlSnapshot, histogramBSnapshot.merge(histogramASnapshot, collectionContext)) - } - } - } - } - - trait HistogramFixture { - val collectionContext = new CollectionContext { - val buffer: LongBuffer = LongBuffer.allocate(10000) - } - - val histogram = Histogram(DynamicRange(1, 100000, 2)) - - def takeSnapshot(): Histogram.Snapshot = histogram.collect(collectionContext) - } - - trait MultipleHistogramFixture { - val collectionContext = new CollectionContext { - val buffer: LongBuffer = LongBuffer.allocate(10000) - } - - val controlHistogram = Histogram(DynamicRange(1, 100000, 2)) - val histogramA = Histogram(DynamicRange(1, 100000, 2)) - val histogramB = Histogram(DynamicRange(1, 100000, 2)) - - def takeSnapshotFrom(histogram: Histogram): InstrumentSnapshot = histogram.collect(collectionContext) - - def assertEquals(left: InstrumentSnapshot, right: InstrumentSnapshot): Unit = { - val leftSnapshot = left.asInstanceOf[Histogram.Snapshot] - val rightSnapshot = right.asInstanceOf[Histogram.Snapshot] - - leftSnapshot.numberOfMeasurements should equal(rightSnapshot.numberOfMeasurements) - leftSnapshot.min should equal(rightSnapshot.min) - leftSnapshot.max should equal(rightSnapshot.max) - leftSnapshot.recordsIterator.toStream should contain theSameElementsAs (rightSnapshot.recordsIterator.toStream) - } - } -} diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/MinMaxCounterSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/instrument/MinMaxCounterSpec.scala deleted file mode 100644 index d007d4cd..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/MinMaxCounterSpec.scala +++ /dev/null @@ -1,140 +0,0 @@ -/* ========================================================================================= - * Copyright © 2013-2014 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.metric.instrument - -import java.nio.LongBuffer - -import akka.actor._ -import akka.testkit.TestProbe -import kamon.Kamon -import kamon.metric.instrument.Histogram.{DynamicRange, MutableRecord} -import kamon.testkit.BaseKamonSpec -import scala.concurrent.duration._ - -class MinMaxCounterSpec extends BaseKamonSpec("min-max-counter-spec") { - - "the MinMaxCounter" should { - "track ascending tendencies" in new MinMaxCounterFixture { - mmCounter.increment() - mmCounter.increment(3) - mmCounter.increment() - - val snapshot = collectCounterSnapshot() - - snapshot.min should be(0) - snapshot.max should be(5) - snapshot.recordsIterator.toStream should contain allOf ( - MutableRecord(0, 1), // min - MutableRecord(5, 2) - ) // max and current - } - - "track descending tendencies" in new MinMaxCounterFixture { - mmCounter.increment(5) - mmCounter.decrement() - mmCounter.decrement(3) - mmCounter.decrement() - - val snapshot = collectCounterSnapshot() - - snapshot.min should be(0) - snapshot.max should be(5) - snapshot.recordsIterator.toStream should contain allOf ( - MutableRecord(0, 2), // min and current - MutableRecord(5, 1) - ) // max - } - - "reset the min and max to the current value after taking a snapshot" in new MinMaxCounterFixture { - mmCounter.increment(5) - mmCounter.decrement(3) - - val firstSnapshot = collectCounterSnapshot() - - firstSnapshot.min should be(0) - firstSnapshot.max should be(5) - firstSnapshot.recordsIterator.toStream should contain allOf ( - MutableRecord(0, 1), // min - MutableRecord(2, 1), // current - MutableRecord(5, 1) - ) // max - - val secondSnapshot = collectCounterSnapshot() - - secondSnapshot.min should be(2) - secondSnapshot.max should be(2) - secondSnapshot.recordsIterator.toStream should contain( - MutableRecord(2, 3) - ) // min, max and current - } - - "report zero as the min and current values if the current value fell bellow zero" in new MinMaxCounterFixture { - mmCounter.decrement(3) - - val snapshot = collectCounterSnapshot() - - snapshot.min should be(0) - snapshot.max should be(0) - snapshot.recordsIterator.toStream should contain( - MutableRecord(0, 3) - ) // min, max and current (even while current really is -3 - } - - "never record values bellow zero in very busy situations" in new MinMaxCounterFixture { - val monitor = TestProbe() - val workers = for (workers ← 1 to 50) yield { - system.actorOf(Props(new MinMaxCounterUpdateActor(mmCounter, monitor.ref))) - } - - workers foreach (_ ! "increment") - for (refresh ← 1 to 1000) { - collectCounterSnapshot() - Thread.sleep(1) - } - - monitor.expectNoMsg() - workers foreach (_ ! PoisonPill) - } - } - - trait MinMaxCounterFixture { - val collectionContext = new CollectionContext { - val buffer: LongBuffer = LongBuffer.allocate(64) - } - - val mmCounter = MinMaxCounter(DynamicRange(1, 1000, 2), 1 hour, Kamon.metrics.settings.refreshScheduler) - mmCounter.cleanup // cancel the refresh schedule - - def collectCounterSnapshot(): Histogram.Snapshot = mmCounter.collect(collectionContext) - } -} - -class MinMaxCounterUpdateActor(mmc: MinMaxCounter, monitor: ActorRef) extends Actor { - val x = Array.ofDim[Int](4) - def receive = { - case "increment" ⇒ - mmc.increment() - self ! "decrement" - case "decrement" ⇒ - mmc.decrement() - self ! "increment" - try { - mmc.refreshValues() - } catch { - case _: IndexOutOfBoundsException ⇒ monitor ! "failed" - } - } -}
\ No newline at end of file diff --git a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/UnitOfMeasurementSpec.scala b/kamon-core/src/legacy-test/scala/kamon/metric/instrument/UnitOfMeasurementSpec.scala deleted file mode 100644 index 7133579e..00000000 --- a/kamon-core/src/legacy-test/scala/kamon/metric/instrument/UnitOfMeasurementSpec.scala +++ /dev/null @@ -1,98 +0,0 @@ -/* - * ========================================================================================= - * 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.metric.instrument - -import kamon.metric.instrument.UnitOfMeasurement.Unknown -import org.scalatest.{Matchers, WordSpec} - -class UnitOfMeasurementSpec extends WordSpec with Matchers { - - "Time unit" should { - "resolve Time Unit by valid name" in { - Time("s") should be(Time.Seconds) - Time("n") should be(Time.Nanoseconds) - Time("ms") should be(Time.Milliseconds) - Time("µs") should be(Time.Microseconds) - } - "fail to resolve Time Unit by invalid name" in { - val ex = intercept[IllegalArgumentException](Time("boo")) - ex.getMessage should be("Can't recognize time unit 'boo'") - } - "scale time properly" in { - val epsilon = 0.0001 - - Time.Nanoseconds.scale(Time.Nanoseconds)(1000000D) should be(1000000D +- epsilon) - Time.Nanoseconds.scale(Time.Microseconds)(1000000D) should be(1000D +- epsilon) - Time.Nanoseconds.scale(Time.Milliseconds)(1000000D) should be(1D +- epsilon) - Time.Nanoseconds.scale(Time.Seconds)(1000000D) should be(0.001D +- epsilon) - Time.Seconds.scale(Time.Nanoseconds)(1D) should be(1000000000D +- epsilon) - } - "allow scale only time" in { - intercept[IllegalArgumentException](Time.Nanoseconds.tryScale(Unknown)(100)) - .getMessage should be("Can't scale different types of units `time` and `unknown`") - intercept[IllegalArgumentException](Time.Nanoseconds.tryScale(Memory.Bytes)(100)) - .getMessage should be("Can't scale different types of units `time` and `bytes`") - val epsilon = 0.0001 - - Time.Nanoseconds.tryScale(Time.Nanoseconds)(100D) should be(100D +- epsilon) - } - } - - "Memory unit" should { - "resolve Memory Unit by valid name" in { - Memory("b") should be(Memory.Bytes) - Memory("Kb") should be(Memory.KiloBytes) - Memory("Mb") should be(Memory.MegaBytes) - Memory("Gb") should be(Memory.GigaBytes) - } - "fail to resolve Memory Unit by invalid name" in { - val ex = intercept[IllegalArgumentException](Memory("boo")) - ex.getMessage should be("Can't recognize memory unit 'boo'") - } - "scale memory properly" in { - val epsilon = 0.0001 - - Memory.Bytes.scale(Memory.Bytes)(1000000D) should be(1000000D +- epsilon) - Memory.Bytes.scale(Memory.KiloBytes)(1000000D) should be(976.5625D +- epsilon) - Memory.Bytes.scale(Memory.MegaBytes)(1000000D) should be(0.9536D +- epsilon) - Memory.Bytes.scale(Memory.GigaBytes)(1000000D) should be(9.3132E-4D +- epsilon) - Memory.MegaBytes.scale(Memory.Bytes)(1D) should be(1048576D +- epsilon) - } - "allow scale only memory" in { - intercept[IllegalArgumentException](Memory.Bytes.tryScale(Unknown)(100)) - .getMessage should be("Can't scale different types of units `bytes` and `unknown`") - intercept[IllegalArgumentException](Memory.Bytes.tryScale(Time.Nanoseconds)(100)) - .getMessage should be("Can't scale different types of units `bytes` and `time`") - val epsilon = 0.0001 - - Memory.Bytes.tryScale(Memory.Bytes)(100D) should be(100D +- epsilon) - } - - } - - "Unknown unit" should { - "allow scale only Unknown" in { - intercept[IllegalArgumentException](Unknown.tryScale(Memory.Bytes)(100)) - .getMessage should be("Can't scale different types of units `unknown` and `bytes`") - intercept[IllegalArgumentException](Unknown.tryScale(Time.Nanoseconds)(100)) - .getMessage should be("Can't scale different types of units `unknown` and `time`") - - Unknown.scale(Unknown)(100D) should be(100D) - } - - } -} |