Instana enablement for frontend

kubernetes-manifests/adservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: addserver
         image: adservice
         ports:
         - containerPort: 9555

kubernetes-manifests/cartservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: cartserver
         image: cartservice
         ports:
         - containerPort: 7070

kubernetes-manifests/checkoutservice.yaml

@@ -26,7 +26,7 @@ spec:
         app: checkoutservice
     spec:
       containers:
-        - name: server
+        - name: checkoutserver
           image: checkoutservice
           ports:
           - containerPort: 5050

kubernetes-manifests/currencyservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: currencyserver
         image: currencyservice
         ports:
         - name: grpc

kubernetes-manifests/emailservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: emailserver
         image: emailservice
         ports:
         - containerPort: 8080

kubernetes-manifests/frontend.yaml

@@ -26,7 +26,7 @@ spec:
         app: frontend
     spec:
       containers:
-        - name: server
+        - name: frontendserver
           image: frontend
           ports:
           - containerPort: 8080
@@ -63,8 +63,14 @@ spec:
             value: "checkoutservice:5050"
           - name: AD_SERVICE_ADDR
             value: "adservice:9555"
-          # - name: JAEGER_SERVICE_ADDR
+          - name: JAEGER_SERVICE_HOST
-          #   value: "jaeger-collector:14268"
+            valueFrom:
+              fieldRef:
+                fieldPath: spec.nodeName
+          - name: JAEGER_SERVICE_PORT
+            value: "42699"
+          - name: JAEGER_SERVICE_PATH
+            value: "/com.instana.plugin.jaeger.trace"
           resources:
             requests:
               cpu: 100m

kubernetes-manifests/paymentservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: paymentserver
         image: paymentservice
         ports:
         - containerPort: 50051

kubernetes-manifests/productcatalogservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: productcatalogserver
         image: productcatalogservice
         ports:
         - containerPort: 3550

kubernetes-manifests/recommendationservice.yaml

@@ -27,7 +27,7 @@ spec:
     spec:
       terminationGracePeriodSeconds: 5
       containers:
-      - name: server
+      - name: recommendationserver
         image: recommendationservice
         ports:
         - containerPort: 8080

kubernetes-manifests/shippingservice.yaml

@@ -26,7 +26,7 @@ spec:
         app: shippingservice
     spec:
       containers:
-      - name: server
+      - name: shippingserver
         image: shippingservice
         ports:
         - containerPort: 50051

src/frontend/main.go

@@ -145,16 +145,21 @@ func main() {
 
 func initJaegerTracing(log logrus.FieldLogger) {
 
-	svcAddr := os.Getenv("JAEGER_SERVICE_ADDR")
+	svcHost := os.Getenv("JAEGER_SERVICE_HOST")
-	if svcAddr == "" {
+	if svcHost == "" {
 		log.Info("jaeger initialization disabled.")
 		return
 	}
 
+	svcPort := os.Getenv("JAEGER_SERVICE_PORT")
+	svcPath := os.Getenv("JAEGER_SERVICE_PATH")
+        svcFull := fmt.Sprintf("http://%s:%s%s", svcHost, svcPort, svcPath)
+
 	// Register the Jaeger exporter to be able to retrieve
 	// the collected spans.
 	exporter, err := jaeger.NewExporter(jaeger.Options{
-		Endpoint: fmt.Sprintf("http://%s", svcAddr),
+		// Endpoint: fmt.Sprintf("http://%s:%s%s", svcHost, svcPort, svcPath),
+		Endpoint: svcFull,
 		Process: jaeger.Process{
 			ServiceName: "frontend",
 		},
@@ -163,7 +168,7 @@ func initJaegerTracing(log logrus.FieldLogger) {
 		log.Fatal(err)
 	}
 	trace.RegisterExporter(exporter)
-	log.Info("jaeger initialization completed.")
+	log.Info("jaeger initialization completed. connected to ", svcFull)
 }
 
 func initStats(log logrus.FieldLogger, exporter *stackdriver.Exporter) {