OTel

OpenTelemetry support for Fiber.

This package is listed on the OpenTelemetry Registry.

Compatible with Fiber v3.

Go version support

We only support the latest two versions of Go. Visit https://go.dev/doc/devel/release for more information.

Install

go get -u github.com/gofiber/contrib/v3/otel

Signature

otel.Middleware(opts ...otel.Option) fiber.Handler

Config

You can configure the middleware using functional parameters

Function	Argument Type	Description	Default
WithNext	func(fiber.Ctx) bool	Define a function to skip this middleware when returned true .	nil
WithTracerProvider	oteltrace.TracerProvider	Specifies a tracer provider to use for creating a tracer.	nil - the global tracer provider is used
WithMeterProvider	otelmetric.MeterProvider	Specifies a meter provider to use for reporting.	nil - the global meter provider is used
WithPort	int	Specifies the value to use when setting the server.port attribute on metrics/spans.	Defaults to (80 for http, 443 for https)
WithPropagators	propagation.TextMapPropagator	Specifies propagators to use for extracting information from the HTTP requests.	If none are specified, global ones will be used
WithTraceResponseHeader	string	Specifies a response header used to expose the current trace ID.	Empty - no dedicated trace ID response header
(❌ Removed) WithServerName	string	This option was removed because the http.server_name attribute is deprecated in the OpenTelemetry semantic conventions. The recommended attribute is server.address, which this middleware already fills with the hostname reported by Fiber.	-
WithSpanNameFormatter	func(fiber.Ctx) string	Takes a function that will be called on every request and the returned string will become the span Name.	Default formatter returns the route pathRaw
WithCustomAttributes	func(fiber.Ctx) []attribute.KeyValue	Define a function to add custom attributes to the span.	nil
WithCustomMetricAttributes	func(fiber.Ctx) []attribute.KeyValue	Define a function to add custom attributes to the metrics.	nil
WithClientIP	bool	Specifies whether to collect the client's IP address from the request.	true
(⚠️ Deprecated) WithCollectClientIP	bool	Deprecated alias for WithClientIP.	true
WithoutMetrics	bool	Disables metrics collection when set to true.	false

Usage

Please refer to example

Metrics Notes

• http.server.request.size and http.server.response.size are measured without buffering full streamed bodies into memory.
• For streamed responses, size is recorded when the stream reaches EOF.
• For text/event-stream responses (SSE), response body size is not recorded.

Trace ID Response Header

You can optionally expose the current trace ID in a dedicated response header:

app.Use(fiberotel.Middleware(
    fiberotel.WithTraceResponseHeader("X-Trace-Id"),
))

Example

package main

import (
    "context"
    "errors"
    "log"

    "go.opentelemetry.io/otel/sdk/resource"

    "github.com/gofiber/fiber/v3"

    fiberotel "github.com/gofiber/contrib/v3/otel"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/attribute"
    stdout "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"

    //"go.opentelemetry.io/otel/exporters/jaeger"
    "go.opentelemetry.io/otel/propagation"
    sdktrace "go.opentelemetry.io/otel/sdk/trace"
    semconv "go.opentelemetry.io/otel/semconv/v1.39.0"
    oteltrace "go.opentelemetry.io/otel/trace"
)

var tracer = otel.Tracer("fiber-server")

func main() {
    tp := initTracer()
    defer func() {
        if err := tp.Shutdown(context.Background()); err != nil {
            log.Printf("Error shutting down tracer provider: %v", err)
        }
    }()

    app := fiber.New()

    app.Use(fiberotel.Middleware())

    app.Get("/error", func(ctx fiber.Ctx) error {
        return errors.New("abc")
    })

    app.Get("/users/:id", func(c fiber.Ctx) error {
        id := c.Params("id")
        name := getUser(c.Context(), id)
        return c.JSON(fiber.Map{"id": id, "name": name})
    })

    log.Fatal(app.Listen(":3000"))
}

func initTracer() *sdktrace.TracerProvider {
    exporter, err := stdout.New(stdout.WithPrettyPrint())
    if err != nil {
        log.Fatal(err)
    }
    tp := sdktrace.NewTracerProvider(
        sdktrace.WithSampler(sdktrace.AlwaysSample()),
        sdktrace.WithBatcher(exporter),
        sdktrace.WithResource(
            resource.NewWithAttributes(
                semconv.SchemaURL,
                semconv.ServiceNameKey.String("my-service"),
            )),
    )
    otel.SetTracerProvider(tp)
    otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))
    return tp
}

func getUser(ctx context.Context, id string) string {
    _, span := tracer.Start(ctx, "getUser", oteltrace.WithAttributes(attribute.String("id", id)))
    defer span.End()
    if id == "123" {
        return "otel tester"
    }
    return "unknown"
}