summaryrefslogtreecommitdiff
path: root/vendor/github.com/uber/jaeger-client-go/reporter.go
diff options
context:
space:
mode:
authorOpenShift Merge Robot <openshift-merge-robot@users.noreply.github.com>2020-05-08 21:34:06 +0200
committerGitHub <noreply@github.com>2020-05-08 21:34:06 +0200
commit7f8b31f5fb59d8b66a26dcd822863fbc18687905 (patch)
tree02ba6090ce80e17cb29d74feb44e43d5ff16090f /vendor/github.com/uber/jaeger-client-go/reporter.go
parentaa74c3f09223107b85b6538a1ffe1e359ff51a65 (diff)
parent5be55739ccf2435e96b52ca64ce1627506927069 (diff)
downloadpodman-7f8b31f5fb59d8b66a26dcd822863fbc18687905.tar.gz
podman-7f8b31f5fb59d8b66a26dcd822863fbc18687905.tar.bz2
podman-7f8b31f5fb59d8b66a26dcd822863fbc18687905.zip
Merge pull request #6049 from containers/dependabot/go_modules/github.com/uber/jaeger-client-go-2.23.1incompatible
build(deps): bump github.com/uber/jaeger-client-go from 2.22.1+incompatible to 2.23.1+incompatible
Diffstat (limited to 'vendor/github.com/uber/jaeger-client-go/reporter.go')
-rw-r--r--vendor/github.com/uber/jaeger-client-go/reporter.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/vendor/github.com/uber/jaeger-client-go/reporter.go b/vendor/github.com/uber/jaeger-client-go/reporter.go
index 830b5a4bb..a71a92c3e 100644
--- a/vendor/github.com/uber/jaeger-client-go/reporter.go
+++ b/vendor/github.com/uber/jaeger-client-go/reporter.go
@@ -257,6 +257,7 @@ func (r *remoteReporter) Report(span *Span) {
// Close implements Close() method of Reporter by waiting for the queue to be drained.
func (r *remoteReporter) Close() {
+ r.logger.Debugf("closing reporter")
if swapped := atomic.CompareAndSwapInt64(&r.closed, 0, 1); !swapped {
r.logger.Error("Repeated attempt to close the reporter is ignored")
return
@@ -307,6 +308,7 @@ func (r *remoteReporter) processQueue() {
r.metrics.ReporterSuccess.Inc(int64(flushed))
// to reduce the number of gauge stats, we only emit queue length on flush
r.metrics.ReporterQueueLength.Update(atomic.LoadInt64(&r.queueLength))
+ r.logger.Debugf("flushed %d spans", flushed)
}
span.Release()
case reporterQueueItemClose: