aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/trace/Sampler.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2017-07-18 10:01:38 +0200
committerIvan Topolnjak <ivantopo@gmail.com>2017-07-18 10:01:38 +0200
commit9b6878da2fbfb1328e972a885a6fdc077e08aaf9 (patch)
tree26392290b76ea3d4b7aaa9a108c315adca803168 /kamon-core/src/main/scala/kamon/trace/Sampler.scala
parent8a035052392ed073cdcb690262c0ef300154918b (diff)
downloadKamon-9b6878da2fbfb1328e972a885a6fdc077e08aaf9.tar.gz
Kamon-9b6878da2fbfb1328e972a885a6fdc077e08aaf9.tar.bz2
Kamon-9b6878da2fbfb1328e972a885a6fdc077e08aaf9.zip
introduce types for Span tags
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/Sampler.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/trace/Sampler.scala6
1 files changed, 3 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/Sampler.scala b/kamon-core/src/main/scala/kamon/trace/Sampler.scala
index e2aefe22..3f366175 100644
--- a/kamon-core/src/main/scala/kamon/trace/Sampler.scala
+++ b/kamon-core/src/main/scala/kamon/trace/Sampler.scala
@@ -19,7 +19,7 @@ import java.util.concurrent.ThreadLocalRandom
import kamon.trace.SpanContext.SamplingDecision
trait Sampler {
- def decide(operationName: String, builderTags: Map[String, String]): SamplingDecision
+ def decide(operationName: String, builderTags: Map[String, Span.TagValue]): SamplingDecision
}
object Sampler {
@@ -37,7 +37,7 @@ object Sampler {
}
class Constant(decision: SamplingDecision) extends Sampler {
- override def decide(operationName: String, builderTags: Map[String, String]): SamplingDecision = decision
+ override def decide(operationName: String, builderTags: Map[String, Span.TagValue]): SamplingDecision = decision
override def toString: String =
s"Sampler.Constant(decision = $decision)"
@@ -47,7 +47,7 @@ object Sampler {
val upperBoundary = Long.MaxValue * probability
val lowerBoundary = -upperBoundary
- override def decide(operationName: String, builderTags: Map[String, String]): SamplingDecision = {
+ override def decide(operationName: String, builderTags: Map[String, Span.TagValue]): SamplingDecision = {
val random = ThreadLocalRandom.current().nextLong()
if(random >= lowerBoundary && random <= upperBoundary) SamplingDecision.Sample else SamplingDecision.DoNotSample
}