Merge branch 'main' into kafka-queue-problems-featureflag

CHANGELOG.md

@@ -23,6 +23,8 @@ the release.
   ([#1522](https://github.com/open-telemetry/opentelemetry-demo/pull/1522))
 * [kafka] add kafkaQueueProblems feature flag
   ([#1528](https://github.com/open-telemetry/opentelemetry-demo/pull/1528))
+* [otelcollector] Add `redisreceiver`
+  ([#1537](https://github.com/open-telemetry/opentelemetry-demo/pull/1537))
 
 ## 1.9.0
 

src/otelcollector/otelcol-config.yml

@@ -13,6 +13,9 @@ receivers:
   httpcheck/frontendproxy:
     targets:
       - endpoint: http://frontendproxy:${env:ENVOY_PORT}
+  redis:
+    endpoint: "redis-cart:6379"
+    collection_interval: 10s
 
 exporters:
   debug:
@@ -44,7 +47,7 @@ service:
       processors: [batch]
       exporters: [otlp, debug, spanmetrics]
     metrics:
-      receivers: [httpcheck/frontendproxy, otlp, spanmetrics]
+      receivers: [httpcheck/frontendproxy, redis, otlp, spanmetrics]
       processors: [batch]
       exporters: [otlphttp/prometheus, debug]
     logs:

src/productcatalogservice/main.go

@@ -128,9 +128,12 @@ func main() {
 		}
 		log.Println("Shutdown meter provider")
 	}()
-	openfeature.SetProvider(flagd.NewProvider())
+	err := openfeature.SetProvider(flagd.NewProvider())
+	if err != nil {
+		log.Fatal(err)
+	}
 
-	err := runtime.Start(runtime.WithMinimumReadMemStatsInterval(time.Second))
+	err = runtime.Start(runtime.WithMinimumReadMemStatsInterval(time.Second))
 	if err != nil {
 		log.Fatal(err)
 	}