local testing, update collector processors

Author: Vadman97

e2e/opentelemetry/go/collector.yml

@@ -13,8 +13,10 @@ receivers:
                 include_metadata: true
 
 exporters:
-    otlp:
-        endpoint: https://otel.observability.app.launchdarkly.com:4317
+    otlphttp:
+      tls:
+        insecure_skip_verify: true
+      endpoint: http://host.docker.internal:4318
 
 processors:
     attributes/environment:
@@ -27,28 +29,30 @@ processors:
     #        value: <LD ENV ID>
     #        action: upsert
 
-    # This filter removes all spans that do not have an HTTP route or any span events
-    # remaining after the previous filter has been applied
-    filter/launchdarkly-spans:
-        error_mode: ignore
-        traces:
-            span:
-                - 'not (attributes["http.route"] != nil or Len(events) > 0)'
-
     batch:
 
+    tail_sampling/keep-errors-and-flags:
+        policies:
+            - name: keep_error_or_flag
+              type: ottl_condition
+              ottl_condition:
+                  error_mode: ignore
+                  spanevent:
+                      - 'name == "exception" or name == "feature_flag"'
+                      # or, if we want to only keep traces with a feature flag that is in a guarded rollout
+                      # - 'name == "exception" or (name == "feature_flag" and attributes["feature_flag.result.reason.inExperiment"] == true)'
+
 service:
     pipelines:
         traces:
             receivers: [otlp]
-            processors:
-                [filter/launchdarkly-spans, attributes/environment, batch]
-            exporters: [otlp]
+            processors: [attributes/environment, batch]
+            exporters: [otlphttp]
         metrics:
             receivers: [otlp]
             processors: [attributes/environment]
-            exporters: [otlp]
+            exporters: [otlphttp]
         logs:
             receivers: [otlp]
             processors: [attributes/environment]
-            exporters: [otlp]
+            exporters: [otlphttp]

e2e/opentelemetry/go/compose.yml

@@ -7,5 +7,5 @@ services:
         volumes:
             - ./collector.yml:/etc/otelcol-contrib/config.yaml
         ports:
-            - '0.0.0.0:4317:4317'
-            - '0.0.0.0:4318:4318'
+            - '0.0.0.0:5317:4317'
+            - '0.0.0.0:5318:4318'

e2e/opentelemetry/go/otel.go

@@ -110,7 +110,7 @@ func newTracerProvider(ctx context.Context, res *resource.Resource) (*trace.Trac
 	// TODO: define the endpoints / https configuration as needed
 
 	traceExporter, err := otlptracehttp.New(ctx,
-		otlptracehttp.WithEndpoint("localhost:4318"),
+		otlptracehttp.WithEndpoint("localhost:5318"),
 		otlptracehttp.WithInsecure(),
 	)
 	if err != nil {
@@ -128,7 +128,7 @@ func newTracerProvider(ctx context.Context, res *resource.Resource) (*trace.Trac
 
 func newMeterProvider(ctx context.Context, res *resource.Resource) (*metric.MeterProvider, error) {
 	metricExporter, err := otlpmetrichttp.New(ctx,
-		otlpmetrichttp.WithEndpoint("localhost:4318"),
+		otlpmetrichttp.WithEndpoint("localhost:5318"),
 		otlpmetrichttp.WithInsecure(),
 	)
 	if err != nil {
@@ -146,7 +146,7 @@ func newMeterProvider(ctx context.Context, res *resource.Resource) (*metric.Mete
 
 func newLoggerProvider(ctx context.Context, res *resource.Resource) (*log.LoggerProvider, error) {
 	logExporter, err := otlploghttp.New(ctx,
-		otlploghttp.WithEndpoint("localhost:4318"),
+		otlploghttp.WithEndpoint("localhost:5318"),
 		otlploghttp.WithInsecure(),
 	)
 	if err != nil {

e2e/opentelemetry/go/rolldice.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"errors"
 	"fmt"
 	"io"
 	"log"
@@ -12,6 +13,7 @@ import (
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
+	"go.opentelemetry.io/otel/trace"
 )
 
 const name = "go.opentelemetry.io/otel/example/dice"
@@ -47,6 +49,18 @@ func rolldice(w http.ResponseWriter, r *http.Request) {
 	}
 	logger.InfoContext(ctx, msg, "result", roll)
 
+	if rand.Intn(100) > 90 {
+		span.RecordError(errors.New("example error"))
+	}
+	if rand.Intn(100) > 50 {
+		span.AddEvent(
+			"feature_flag",
+			trace.WithAttributes(
+				attribute.String("feature_flag.key", "foo"),
+				attribute.Bool("feature_flag.result.reason.inExperiment", rand.Intn(100) > 90),
+			))
+	}
+
 	rollValueAttr := attribute.Int("roll.value", roll)
 	span.SetAttributes(rollValueAttr)
 	rollCnt.Add(ctx, 1, metric.WithAttributes(rollValueAttr))
@@ -55,4 +69,4 @@ func rolldice(w http.ResponseWriter, r *http.Request) {
 	if _, err := io.WriteString(w, resp); err != nil {
 		log.Printf("Write failed: %v\n", err)
 	}
-}
+}