aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala')
-rw-r--r--kamon-core/src/main/scala/kamon/trace/Sampler.scala20
-rw-r--r--kamon-core/src/main/scala/kamon/trace/Tracer.scala8
2 files changed, 14 insertions, 14 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/Sampler.scala b/kamon-core/src/main/scala/kamon/trace/Sampler.scala
index f478bbd1..e2aefe22 100644
--- a/kamon-core/src/main/scala/kamon/trace/Sampler.scala
+++ b/kamon-core/src/main/scala/kamon/trace/Sampler.scala
@@ -23,15 +23,15 @@ trait Sampler {
}
object Sampler {
- val always = new Constant(SamplingDecision.Sample)
- val never = new Constant(SamplingDecision.DoNotSample)
+ val Always = new Constant(SamplingDecision.Sample)
+ val Never = new Constant(SamplingDecision.DoNotSample)
- def random(chance: Double): Sampler = {
- assert(chance >= 0D && chance <= 1.0D, "Change should be >= 0 and <= 1.0")
+ def random(probability: Double): Sampler = {
+ assert(probability >= 0D && probability <= 1.0D, "The probability should be >= 0 and <= 1.0")
- chance match {
- case 0D => never
- case 1.0D => always
+ probability match {
+ case 0D => Never
+ case 1.0D => Always
case anyOther => new Random(anyOther)
}
}
@@ -43,8 +43,8 @@ object Sampler {
s"Sampler.Constant(decision = $decision)"
}
- class Random(chance: Double) extends Sampler {
- val upperBoundary = Long.MaxValue * chance
+ class Random(probability: Double) extends Sampler {
+ val upperBoundary = Long.MaxValue * probability
val lowerBoundary = -upperBoundary
override def decide(operationName: String, builderTags: Map[String, String]): SamplingDecision = {
@@ -53,6 +53,6 @@ object Sampler {
}
override def toString: String =
- s"Sampler.Random(chance = $chance)"
+ s"Sampler.Random(probability = $probability)"
}
}
diff --git a/kamon-core/src/main/scala/kamon/trace/Tracer.scala b/kamon-core/src/main/scala/kamon/trace/Tracer.scala
index ecc690af..85d02c8d 100644
--- a/kamon-core/src/main/scala/kamon/trace/Tracer.scala
+++ b/kamon-core/src/main/scala/kamon/trace/Tracer.scala
@@ -51,7 +51,7 @@ object Tracer {
private[Tracer] val tracerMetrics = new TracerMetrics(metrics)
@volatile private[Tracer] var joinRemoteSpansWithSameID: Boolean = false
- @volatile private[Tracer] var configuredSampler: Sampler = Sampler.never
+ @volatile private[Tracer] var configuredSampler: Sampler = Sampler.Never
@volatile private[Tracer] var identityProvider: IdentityProvider = IdentityProvider.Default()
@volatile private[Tracer] var textMapSpanContextCodec: SpanContextCodec[TextMap] = SpanContextCodec.ExtendedB3(identityProvider)
@volatile private[Tracer] var httpHeaderSpanContextCodec: SpanContextCodec[TextMap] = SpanContextCodec.ExtendedB3(identityProvider)
@@ -99,9 +99,9 @@ object Tracer {
val traceConfig = config.getConfig("kamon.trace")
configuredSampler = traceConfig.getString("sampler") match {
- case "always" => Sampler.always
- case "never" => Sampler.never
- case "random" => Sampler.random(traceConfig.getDouble("sampler-random.chance"))
+ case "always" => Sampler.Always
+ case "never" => Sampler.Never
+ case "random" => Sampler.random(traceConfig.getDouble("random-sampler.probability"))
case other => sys.error(s"Unexpected sampler name $other.")
}
}