diff options
Diffstat (limited to 'kamon-core/src/test/scala/kamon/util')
4 files changed, 0 insertions, 274 deletions
diff --git a/kamon-core/src/test/scala/kamon/util/GlobPathFilterSpec.scala b/kamon-core/src/test/scala/kamon/util/GlobPathFilterSpec.scala deleted file mode 100644 index 7d585087..00000000 --- a/kamon-core/src/test/scala/kamon/util/GlobPathFilterSpec.scala +++ /dev/null @@ -1,73 +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.util - -import org.scalatest.{Matchers, WordSpecLike} - -class GlobPathFilterSpec extends WordSpecLike with Matchers { - "The GlobPathFilter" should { - - "match a single expression" in { - val filter = new GlobPathFilter("/user/actor") - - filter.accept("/user/actor") shouldBe true - - filter.accept("/user/actor/something") shouldBe false - filter.accept("/user/actor/somethingElse") shouldBe false - } - - "match all expressions in the same level" in { - val filter = new GlobPathFilter("/user/*") - - filter.accept("/user/actor") shouldBe true - filter.accept("/user/otherActor") shouldBe true - - filter.accept("/user/something/actor") shouldBe false - filter.accept("/user/something/otherActor") shouldBe false - } - - "match all expressions in the same levelss" in { - val filter = new GlobPathFilter("**") - - filter.accept("GET: /ping") shouldBe true - filter.accept("GET: /ping/pong") shouldBe true - } - - "match all expressions and crosses the path boundaries" in { - val filter = new GlobPathFilter("/user/actor-**") - - filter.accept("/user/actor-") shouldBe true - filter.accept("/user/actor-one") shouldBe true - filter.accept("/user/actor-one/other") shouldBe true - - filter.accept("/user/something/actor") shouldBe false - filter.accept("/user/something/otherActor") shouldBe false - } - - "match exactly one character" in { - val filter = new GlobPathFilter("/user/actor-?") - - filter.accept("/user/actor-1") shouldBe true - filter.accept("/user/actor-2") shouldBe true - filter.accept("/user/actor-3") shouldBe true - - filter.accept("/user/actor-one") shouldBe false - filter.accept("/user/actor-two") shouldBe false - filter.accept("/user/actor-tree") shouldBe false - } - } -} diff --git a/kamon-core/src/test/scala/kamon/util/NeedToScaleSpec.scala b/kamon-core/src/test/scala/kamon/util/NeedToScaleSpec.scala deleted file mode 100644 index cba6ad98..00000000 --- a/kamon-core/src/test/scala/kamon/util/NeedToScaleSpec.scala +++ /dev/null @@ -1,67 +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.util - -import com.typesafe.config.ConfigFactory -import kamon.metric.instrument.{Memory, Time} -import org.scalatest.{Matchers, WordSpec} - -class NeedToScaleSpec extends WordSpec with Matchers { - - "NeedToScale" should { - "extract time unit to scale to from config" in { - val config = ConfigFactory.parseString( - """ - |time-units = "ms" - """.stripMargin - ) - - config match { - case NeedToScale(timeUnits, memoryUnits) ⇒ - timeUnits should be(Some(Time.Milliseconds)) - memoryUnits should be(None) - } - } - "extract memory unit to scale to from config" in { - val config = ConfigFactory.parseString( - """ - |memory-units = "kb" - """.stripMargin - ) - - config match { - case NeedToScale(timeUnits, memoryUnits) ⇒ - timeUnits should be(None) - memoryUnits should be(Some(Memory.KiloBytes)) - } - } - "extract nothing if config has no proper keys" in { - val config = ConfigFactory.parseString( - """ - |some-other-key = "value" - """.stripMargin - ) - - config match { - case NeedToScale(timeUnits, memoryUnits) ⇒ - fail("Should not match") - case _ ⇒ - } - } - } - -} diff --git a/kamon-core/src/test/scala/kamon/util/RegexPathFilterSpec.scala b/kamon-core/src/test/scala/kamon/util/RegexPathFilterSpec.scala deleted file mode 100644 index a2cc8629..00000000 --- a/kamon-core/src/test/scala/kamon/util/RegexPathFilterSpec.scala +++ /dev/null @@ -1,59 +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.util - -import org.scalatest.{Matchers, WordSpecLike} - -class RegexPathFilterSpec extends WordSpecLike with Matchers { - "The RegexPathFilter" should { - - "match a single expression" in { - val filter = new RegexPathFilter("/user/actor") - - filter.accept("/user/actor") shouldBe true - - filter.accept("/user/actor/something") shouldBe false - filter.accept("/user/actor/somethingElse") shouldBe false - } - - "match arbitray expressions ending with wildcard" in { - val filter = new RegexPathFilter("/user/.*") - - filter.accept("/user/actor") shouldBe true - filter.accept("/user/otherActor") shouldBe true - filter.accept("/user/something/actor") shouldBe true - filter.accept("/user/something/otherActor") shouldBe true - - filter.accept("/otheruser/actor") shouldBe false - filter.accept("/otheruser/otherActor") shouldBe false - filter.accept("/otheruser/something/actor") shouldBe false - filter.accept("/otheruser/something/otherActor") shouldBe false - } - - "match numbers" in { - val filter = new RegexPathFilter("/user/actor-\\d") - - filter.accept("/user/actor-1") shouldBe true - filter.accept("/user/actor-2") shouldBe true - filter.accept("/user/actor-3") shouldBe true - - filter.accept("/user/actor-one") shouldBe false - filter.accept("/user/actor-two") shouldBe false - filter.accept("/user/actor-tree") shouldBe false - } - } -} diff --git a/kamon-core/src/test/scala/kamon/util/executors/ExecutorServiceMetricsSpec.scala b/kamon-core/src/test/scala/kamon/util/executors/ExecutorServiceMetricsSpec.scala deleted file mode 100644 index 4e5394f8..00000000 --- a/kamon-core/src/test/scala/kamon/util/executors/ExecutorServiceMetricsSpec.scala +++ /dev/null @@ -1,75 +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.util.executors - -import java.util.concurrent.Executors - -import kamon.Kamon -import kamon.metric.{Entity, EntityRecorder} -import kamon.testkit.BaseKamonSpec - -class ExecutorServiceMetricsSpec extends BaseKamonSpec("executor-service-metrics-spec") { - - "the ExecutorServiceMetrics" should { - "register a SingleThreadPool, collect their metrics and remove it" in { - val singleThreadPoolExecutor = Executors.newSingleThreadExecutor() - val singleThreadPoolExecutorEntity = ExecutorServiceMetrics.register("single-thread-pool", singleThreadPoolExecutor) - findExecutorRecorder(singleThreadPoolExecutorEntity) should not be empty - - ExecutorServiceMetrics.remove(singleThreadPoolExecutorEntity) - findExecutorRecorder(singleThreadPoolExecutorEntity) should be(empty) - } - - "register a ThreadPoolExecutor, collect their metrics and remove it" in { - val threadPoolExecutor = Executors.newCachedThreadPool() - val threadPoolExecutorEntity = ExecutorServiceMetrics.register("thread-pool-executor", threadPoolExecutor) - findExecutorRecorder(threadPoolExecutorEntity) should not be empty - - ExecutorServiceMetrics.remove(threadPoolExecutorEntity) - findExecutorRecorder(threadPoolExecutorEntity) should be(empty) - } - - "register a ScheduledThreadPoolExecutor, collect their metrics and remove it" in { - val scheduledThreadPoolExecutor = Executors.newSingleThreadScheduledExecutor() - val scheduledThreadPoolEntity = ExecutorServiceMetrics.register("scheduled-thread-pool-executor", scheduledThreadPoolExecutor) - findExecutorRecorder(scheduledThreadPoolEntity) should not be empty - - ExecutorServiceMetrics.remove(scheduledThreadPoolEntity) - findExecutorRecorder(scheduledThreadPoolEntity) should be(empty) - } - - "register a Java ForkJoinPool, collect their metrics and remove it" in { - val javaForkJoinPool = Executors.newWorkStealingPool() - val javaForkJoinPoolEntity = ExecutorServiceMetrics.register("java-fork-join-pool", javaForkJoinPool) - findExecutorRecorder(javaForkJoinPoolEntity) should not be empty - - ExecutorServiceMetrics.remove(javaForkJoinPoolEntity) - findExecutorRecorder(javaForkJoinPoolEntity) should be(empty) - } - - "register a Scala ForkJoinPool, collect their metrics and remove it" in { - val scalaForkJoinPool = new scala.concurrent.forkjoin.ForkJoinPool() - val scalaForkJoinPoolEntity = ExecutorServiceMetrics.register("scala-fork-join-pool", scalaForkJoinPool) - findExecutorRecorder(scalaForkJoinPoolEntity) should not be empty - - ExecutorServiceMetrics.remove(scalaForkJoinPoolEntity) - findExecutorRecorder(scalaForkJoinPoolEntity) should be(empty) - } - - def findExecutorRecorder(entity: Entity): Option[EntityRecorder] = Kamon.metrics.find(entity) - } -} |