diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-08-15 00:15:21 +0200 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2017-08-15 00:15:21 +0200 |
commit | 86c72d622ac027dc96f9a744771c0a468d46dc60 (patch) | |
tree | 9a60060496df2151c3d4e7e2159106e797306550 /kamon-core/src/main/scala/kamon/util | |
parent | 6721d325d018756296213ac8f9129bc304a21afb (diff) | |
download | Kamon-86c72d622ac027dc96f9a744771c0a468d46dc60.tar.gz Kamon-86c72d622ac027dc96f9a744771c0a468d46dc60.tar.bz2 Kamon-86c72d622ac027dc96f9a744771c0a468d46dc60.zip |
move ALMaxUpdater and MeasurementUnit to kamon.metric
Diffstat (limited to 'kamon-core/src/main/scala/kamon/util')
-rw-r--r-- | kamon-core/src/main/scala/kamon/util/AtomicLongMaxUpdater.scala | 40 | ||||
-rw-r--r-- | kamon-core/src/main/scala/kamon/util/MeasurementUnit.scala | 81 |
2 files changed, 0 insertions, 121 deletions
diff --git a/kamon-core/src/main/scala/kamon/util/AtomicLongMaxUpdater.scala b/kamon-core/src/main/scala/kamon/util/AtomicLongMaxUpdater.scala deleted file mode 100644 index 36c01c83..00000000 --- a/kamon-core/src/main/scala/kamon/util/AtomicLongMaxUpdater.scala +++ /dev/null @@ -1,40 +0,0 @@ -/* ========================================================================================= - * Copyright © 2013-2017 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 java.util.concurrent.atomic.AtomicLong - -import scala.annotation.tailrec - -class AtomicLongMaxUpdater(value:AtomicLong) { - - def update(newMax:Long):Unit = { - @tailrec def compare():Long = { - val currentMax = value.get() - if(newMax > currentMax) if (!value.compareAndSet(currentMax, newMax)) compare() else newMax - else currentMax - } - compare() - } - - def maxThenReset(newValue:Long): Long = - value.getAndSet(newValue) -} - -object AtomicLongMaxUpdater { - def apply(): AtomicLongMaxUpdater = - new AtomicLongMaxUpdater(new AtomicLong(0)) -}
\ No newline at end of file diff --git a/kamon-core/src/main/scala/kamon/util/MeasurementUnit.scala b/kamon-core/src/main/scala/kamon/util/MeasurementUnit.scala deleted file mode 100644 index f5764ad1..00000000 --- a/kamon-core/src/main/scala/kamon/util/MeasurementUnit.scala +++ /dev/null @@ -1,81 +0,0 @@ -/* ========================================================================================= - * Copyright © 2013-2017 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 kamon.util.MeasurementUnit.{Dimension, Magnitude} - -/** - * A MeasurementUnit is a simple representation of the dimension and magnitude of a quantity being measured, such as - * "Time in Seconds" or "Data in Kilobytes". - */ -case class MeasurementUnit(dimension: Dimension, magnitude: Magnitude) - -object MeasurementUnit { - val none = MeasurementUnit(Dimension.None, Magnitude("none", 1D)) - - val time: TimeUnits = new TimeUnits { - val seconds = MeasurementUnit(Dimension.Time, Magnitude("seconds", 1D)) - val milliseconds = MeasurementUnit(Dimension.Time, Magnitude("milliseconds", 1e-3)) - val microseconds = MeasurementUnit(Dimension.Time, Magnitude("microseconds", 1e-6)) - val nanoseconds = MeasurementUnit(Dimension.Time, Magnitude("nanoseconds", 1e-9)) - } - - val information: DataUnits = new DataUnits { - val bytes = MeasurementUnit(Dimension.Information, Magnitude("byte", 1)) - val kilobytes = MeasurementUnit(Dimension.Information, Magnitude("kilobytes", 1024)) - val megabytes = MeasurementUnit(Dimension.Information, Magnitude("megabytes", 1024 * 1024)) - val gigabytes = MeasurementUnit(Dimension.Information, Magnitude("gigabytes", 1024 * 1024 * 1024)) - } - - /** - * Scales the provided value between two MeasurementUnits of the same dimension. - * - * @param value value to be scaled. - * @param from value's [[MeasurementUnit]]. - * @param to target [[MeasurementUnit]]. - * @return equivalent of the provided value on the target [[MeasurementUnit]] - */ - def scale(value: Long, from: MeasurementUnit, to: MeasurementUnit): Double = { - if(from.dimension != to.dimension) - sys.error(s"Can't scale values from the [${from.dimension.name}] dimension into the [${to.dimension.name}] dimension.") - else if(from == to) - value.toDouble - else (from.magnitude.scaleFactor / to.magnitude.scaleFactor) * value.toDouble - } - - case class Dimension(name: String) - case class Magnitude(name: String, scaleFactor: Double) - - object Dimension { - val None = Dimension("none") - val Time = Dimension("time") - val Information = Dimension("information") - } - - trait TimeUnits { - def seconds: MeasurementUnit - def milliseconds: MeasurementUnit - def microseconds: MeasurementUnit - def nanoseconds: MeasurementUnit - } - - trait DataUnits { - def bytes: MeasurementUnit - def kilobytes: MeasurementUnit - def megabytes: MeasurementUnit - def gigabytes: MeasurementUnit - } -} |