[agent] Process data loss stats from clients (#2010)

* Collect data loss metrics from clients Signed-off-by: Yuri Shkuro <ys@uber.com> * Regenerate thrift Signed-off-by: Yuri Shkuro <ys@uber.com> * Prototype Signed-off-by: Yuri Shkuro <ys@uber.com> * Upgrade Jaeger client Signed-off-by: Yuri Shkuro <ys@uber.com> * Handle wrapped counters Signed-off-by: Yuri Shkuro <ys@uber.com> * Fix formatting Signed-off-by: Yuri Shkuro <ys@uber.com> * Move to new file Signed-off-by: Yuri Shkuro <ys@uber.com> * Shutdown Signed-off-by: Yuri Shkuro <ys@uber.com> * Undo unnecessary change Signed-off-by: Yuri Shkuro <ys@uber.com> * regenerate Signed-off-by: Yuri Shkuro <ys@uber.com> * Add logging Signed-off-by: Yuri Shkuro <ys@uber.com> * cleanup Signed-off-by: Yuri Shkuro <ys@uber.com> * delint Signed-off-by: Yuri Shkuro <ys@uber.com> * Add some tests Signed-off-by: Yuri Shkuro <ys@uber.com> * Clean up Signed-off-by: Yuri Shkuro <ys@uber.com> * more tests Signed-off-by: Yuri Shkuro <ys@uber.com> * More tests Signed-off-by: Yuri Shkuro <ys@uber.com> * Reduce nesting Signed-off-by: Yuri Shkuro <ys@uber.com> * ignore overflow Signed-off-by: Yuri Shkuro <ys@uber.com> * deps Signed-off-by: Yuri Shkuro <ys@uber.com> * test Signed-off-by: Yuri Shkuro <ys@uber.com> * rename Signed-off-by: Yuri Shkuro <ys@uber.com> * comments Signed-off-by: Yuri Shkuro <ys@uber.com>
jaegertracing · Jan 15, 2020 · 43be2e7 · 43be2e7
1 parent 641dd92
commit 43be2e7
Show file tree

Hide file tree

Showing 32 changed files with 836 additions and 95 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Gopkg.toml b/Gopkg.toml
@@ -105,7 +105,7 @@ required = [
 
 [[constraint]]
   name = "github.com/uber/jaeger-client-go"
-  version = "^2.19.0"
+  version = "^2.22.0"
 
 [[constraint]]
   name = "github.com/uber/jaeger-lib"

diff --git a/Makefile b/Makefile
@@ -203,6 +203,10 @@ docker-hotrod:
 	GOOS=linux $(MAKE) build-examples
 	docker build -t $(DOCKER_NAMESPACE)/example-hotrod:${DOCKER_TAG} ./examples/hotrod
 
+.PHONY: run-all-in-one
+run-all-in-one:
+	go run -tags ui ./cmd/all-in-one --log-level debug
+
 .PHONY: build-ui
 build-ui:
 	cd jaeger-ui && yarn install --frozen-lockfile && cd packages/jaeger-ui && yarn build

diff --git a/cmd/agent/app/processors/thrift_processor.go b/cmd/agent/app/processors/thrift_processor.go
@@ -44,7 +44,10 @@ type ThriftProcessor struct {
 	}
 }
 
-// AgentProcessor handler used by the processor to process thrift and call the reporter with the deserialized struct
+// AgentProcessor handler used by the processor to process thrift and call the reporter
+// with the deserialized struct. This interface is implemented directly by Thrift generated
+// code, e.g. jaegerThrift.NewAgentProcessor(handler), where handler implements the Agent
+// Thrift service interface, which is invoked with the the deserialized struct.
 type AgentProcessor interface {
 	Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
 }