mirror of
https://github.com/containers/podman.git
synced 2025-12-14 11:00:10 +08:00
build(deps): bump github.com/uber/jaeger-client-go
Bumps [github.com/uber/jaeger-client-go](https://github.com/uber/jaeger-client-go) from 2.22.1+incompatible to 2.23.1+incompatible. - [Release notes](https://github.com/uber/jaeger-client-go/releases) - [Changelog](https://github.com/jaegertracing/jaeger-client-go/blob/master/CHANGELOG.md) - [Commits](https://github.com/uber/jaeger-client-go/compare/v2.22.1...v2.23.1) Signed-off-by: dependabot-preview[bot] <support@dependabot.com> Signed-off-by: Daniel J Walsh <dwalsh@redhat.com>
This commit is contained in:
committed by
Daniel J Walsh
parent
99f8cfc2dc
commit
5be55739cc
24
vendor/github.com/uber/jaeger-client-go/sampler.go
generated
vendored
24
vendor/github.com/uber/jaeger-client-go/sampler.go
generated
vendored
@@ -17,6 +17,7 @@ package jaeger
|
||||
import (
|
||||
"fmt"
|
||||
"math"
|
||||
"strings"
|
||||
"sync"
|
||||
|
||||
"github.com/uber/jaeger-client-go/thrift-gen/sampling"
|
||||
@@ -141,7 +142,7 @@ func (s *ProbabilisticSampler) SamplingRate() float64 {
|
||||
|
||||
// IsSampled implements IsSampled() of Sampler.
|
||||
func (s *ProbabilisticSampler) IsSampled(id TraceID, operation string) (bool, []Tag) {
|
||||
return s.samplingBoundary >= id.Low, s.tags
|
||||
return s.samplingBoundary >= id.Low&maxRandomNumber, s.tags
|
||||
}
|
||||
|
||||
// Close implements Close() of Sampler.
|
||||
@@ -319,6 +320,10 @@ func (s *GuaranteedThroughputProbabilisticSampler) update(lowerBound, samplingRa
|
||||
}
|
||||
}
|
||||
|
||||
func (s GuaranteedThroughputProbabilisticSampler) String() string {
|
||||
return fmt.Sprintf("GuaranteedThroughputProbabilisticSampler(lowerBound=%f, samplingRate=%f)", s.lowerBound, s.samplingRate)
|
||||
}
|
||||
|
||||
// -----------------------
|
||||
|
||||
// PerOperationSampler is a delegating sampler that applies GuaranteedThroughputProbabilisticSampler
|
||||
@@ -456,6 +461,23 @@ func (s *PerOperationSampler) Close() {
|
||||
s.defaultSampler.Close()
|
||||
}
|
||||
|
||||
func (s *PerOperationSampler) String() string {
|
||||
var sb strings.Builder
|
||||
|
||||
fmt.Fprintf(&sb, "PerOperationSampler(defaultSampler=%v, ", s.defaultSampler)
|
||||
fmt.Fprintf(&sb, "lowerBound=%f, ", s.lowerBound)
|
||||
fmt.Fprintf(&sb, "maxOperations=%d, ", s.maxOperations)
|
||||
fmt.Fprintf(&sb, "operationNameLateBinding=%t, ", s.operationNameLateBinding)
|
||||
fmt.Fprintf(&sb, "numOperations=%d,\n", len(s.samplers))
|
||||
fmt.Fprintf(&sb, "samplers=[")
|
||||
for operationName, sampler := range s.samplers {
|
||||
fmt.Fprintf(&sb, "\n(operationName=%s, sampler=%v)", operationName, sampler)
|
||||
}
|
||||
fmt.Fprintf(&sb, "])")
|
||||
|
||||
return sb.String()
|
||||
}
|
||||
|
||||
// Equal is not used.
|
||||
// TODO (breaking change) remove this in the future
|
||||
func (s *PerOperationSampler) Equal(other Sampler) bool {
|
||||
|
||||
Reference in New Issue
Block a user