/* ========================================================================================= * Copyright © 2013-2017 the kamon project * * 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 org.scalatest.{Matchers, WordSpec} class LongAdderCounterSpec extends WordSpec with Matchers { "a LongAdderCounter" should { "allow unit and bundled increments" in { val counter = buildCounter("unit-increments") counter.increment() counter.increment() counter.increment(40) counter.snapshot().value shouldBe 42 } "warn the user and ignore attempts to decrement the counter" in { val counter = buildCounter("attempt-to-decrement") counter.increment(100) counter.increment(100) counter.increment(100) counter.snapshot().value shouldBe 300 } "reset the internal state to zero after taking snapshots as a default behavior" in { val counter = buildCounter("reset-after-snapshot") counter.increment() counter.increment(10) counter.snapshot().value shouldBe 11 counter.snapshot().value shouldBe 0 } "optionally leave the internal state unchanged" in { val counter = buildCounter("reset-after-snapshot") counter.increment() counter.increment(10) counter.snapshot(resetState = false).value shouldBe 11 counter.snapshot(resetState = false).value shouldBe 11 } } def buildCounter(name: String, tags: Map[String, String] = Map.empty, unit: MeasurementUnit = MeasurementUnit.none): LongAdderCounter = new LongAdderCounter(name, tags, unit) }