Allow for disabling client IP collection in traces

otelfiber/config.go

@@ -18,6 +18,7 @@ type config struct {
 	ServerName        *string
 	SpanNameFormatter func(*fiber.Ctx) string
 	CustomAttributes  func(*fiber.Ctx) []attribute.KeyValue
+	collectClientIP   bool
 }
 
 // Option specifies instrumentation configuration options.
@@ -96,3 +97,11 @@ func WithCustomAttributes(f func(ctx *fiber.Ctx) []attribute.KeyValue) Option {
 		cfg.CustomAttributes = f
 	})
 }
+
+// WithCollectClientIP specifies whether to collect the client's IP address
+// from the request. This is enabled by default.
+func WithCollectClientIP(collect bool) Option {
+	return optionFunc(func(cfg *config) {
+		cfg.collectClientIP = collect
+	})
+}

otelfiber/fiber.go

@@ -33,7 +33,9 @@ const (
 
 // Middleware returns fiber handler which will trace incoming requests.
 func Middleware(opts ...Option) fiber.Handler {
-	cfg := config{}
+	cfg := config{
+		collectClientIP: true,
+	}
 	for _, opt := range opts {
 		opt.apply(&cfg)
 	}

otelfiber/otelfiber_test/fiber_test.go

@@ -496,3 +496,41 @@ func TestOutboundTracingPropagationWithInboundContext(t *testing.T) {
 	assert.Equal(t, traceId, resp.Header.Get("X-B3-TraceId"))
 	assert.Equal(t, "1", resp.Header.Get("X-B3-Sampled"))
 }
+
+func TestCollectClientIP(t *testing.T) {
+	t.Parallel()
+
+	for _, enabled := range []bool{true, false} {
+		enabled := enabled
+		t.Run(fmt.Sprintf("enabled=%t", enabled), func(t *testing.T) {
+			t.Parallel()
+
+			sr := tracetest.NewSpanRecorder()
+			provider := sdktrace.NewTracerProvider(sdktrace.WithSpanProcessor(sr))
+			otel.SetTracerProvider(provider)
+
+			app := fiber.New()
+			app.Use(otelfiber.Middleware(
+				otelfiber.WithTracerProvider(provider),
+				otelfiber.WithCollectClientIP(enabled),
+			))
+			app.Get("/foo", func(ctx *fiber.Ctx) error {
+				return ctx.SendStatus(http.StatusNoContent)
+			})
+
+			req := httptest.NewRequest("GET", "/foo", nil)
+			_, _ = app.Test(req)
+
+			spans := sr.Ended()
+			require.Len(t, spans, 1)
+
+			span := spans[0]
+			attrs := span.Attributes()
+			if enabled {
+				assert.Contains(t, attrs, attribute.String("http.client_ip", "0.0.0.0"))
+			} else {
+				assert.NotContains(t, attrs, attribute.String("http.client_ip", "0.0.0.0"))
+			}
+		})
+	}
+}

otelfiber/semconv.go

@@ -56,9 +56,11 @@ func httpServerTraceAttributesFromRequest(c *fiber.Ctx, cfg config) []attribute.
 	if username, ok := HasBasicAuth(c.Get(fiber.HeaderAuthorization)); ok {
 		attrs = append(attrs, semconv.EnduserIDKey.String(utils.CopyString(username)))
 	}
-	clientIP := c.IP()
-	if len(clientIP) > 0 {
-		attrs = append(attrs, semconv.HTTPClientIPKey.String(utils.CopyString(clientIP)))
+	if cfg.collectClientIP {
+		clientIP := c.IP()
+		if len(clientIP) > 0 {
+			attrs = append(attrs, semconv.HTTPClientIPKey.String(utils.CopyString(clientIP)))
+		}
 	}
 
 	if cfg.CustomAttributes != nil {