Enabled DNS as the service discovery mechanism for agent => collector…

… communication Signed-off-by: Juraci Paixão Kröhling <[email protected]>
jaegertracing · Mar 19, 2019 · ff3856e · ff3856e
1 parent ca44c74
commit ff3856e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/pkg/deployment/agent.go b/pkg/deployment/agent.go
@@ -38,7 +38,7 @@ func (a *Agent) Get() *appsv1.DaemonSet {
 
 	args := append(a.jaeger.Spec.Agent.Options.ToArgs(),
 		"--reporter.type=grpc",
-		fmt.Sprintf("--reporter.grpc.host-port=%s:14250", service.GetNameForCollectorService(a.jaeger)))
+		fmt.Sprintf("--reporter.grpc.host-port=dns:///%s:14250", service.GetNameForCollectorService(a.jaeger)))
 	trueVar := true
 	labels := a.labels()
 

diff --git a/pkg/inject/sidecar.go b/pkg/inject/sidecar.go
@@ -86,7 +86,10 @@ func Select(target *appsv1.Deployment, availableJaegerPods *v1.JaegerList) *v1.J
 }
 
 func container(jaeger *v1.Jaeger) corev1.Container {
-	args := append(jaeger.Spec.Agent.Options.ToArgs(), fmt.Sprintf("--collector.host-port=%s.%s:14267", service.GetNameForCollectorService(jaeger), jaeger.Namespace))
+	args := append(jaeger.Spec.Agent.Options.ToArgs(),
+		"--reporter.type=grpc",
+		fmt.Sprintf("--reporter.grpc.host-port=dns:///%s.%s:14250", service.GetNameForCollectorService(jaeger), jaeger.Namespace),
+	)
 	return corev1.Container{
 		Image: jaeger.Spec.Agent.Image,
 		Name:  "jaeger-agent",