Revert "Instana enablement for frontend"

This reverts commit ad5939d7f0.
This commit is contained in:
LutzLange 2020-04-17 10:30:16 +02:00
parent ad5939d7f0
commit 13db5982f7
11 changed files with 16 additions and 27 deletions

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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

View file

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