From d9bf61bbde1397426988c79ec45a8696594e4dbb Mon Sep 17 00:00:00 2001 From: Przemek Maciolek Date: Thu, 5 Mar 2020 16:38:53 +0100 Subject: [PATCH] Handle Zipkin processing --- processor/k8sprocessor/processor.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/processor/k8sprocessor/processor.go b/processor/k8sprocessor/processor.go index eab6ee62a963..68d58cb88498 100644 --- a/processor/k8sprocessor/processor.go +++ b/processor/k8sprocessor/processor.go @@ -30,6 +30,7 @@ import ( const ( sourceFormatJaeger string = "jaeger" + sourceFormatZipkin string = "zipkin" ipLabelName string = "ip" ) @@ -95,7 +96,8 @@ func (kp *kubernetesprocessor) ConsumeTraceData(ctx context.Context, td consumer // Jaeger client libs tag the process with the process/resource IP and // jaeger to OC translator maps jaeger process to OC node. // TODO: Should jaeger translator map jaeger process to OC resource instead? - if podIP == "" && td.SourceFormat == sourceFormatJaeger { + // Zipkin format is grouped by common endpoints as Node by receiver + if podIP == "" && (td.SourceFormat == sourceFormatJaeger || td.SourceFormat == sourceFormatZipkin) { if td.Node != nil { podIP = td.Node.Attributes[ipLabelName] }