Go

go get go.opentelemetry.io/otel \
       go.opentelemetry.io/otel/sdk \
       go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp \
       go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp

package main

import (
    "context"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/attribute"
    "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp"
    "go.opentelemetry.io/otel/sdk/resource"
    sdktrace "go.opentelemetry.io/otel/sdk/trace"
    semconv "go.opentelemetry.io/otel/semconv/v1.26.0"
)

func initTracer(ctx context.Context) (*sdktrace.TracerProvider, error) {
    exporter, err := otlptracehttp.New(ctx,
        otlptracehttp.WithEndpoint("ingress.rocketlog.io"), // host only, no scheme
        otlptracehttp.WithHeaders(map[string]string{
            "Authorization": "Bearer rg_live_xxxxxx",
        }),
    )
    if err != nil {
        return nil, err
    }

    res, _ := resource.New(ctx, resource.WithAttributes(
        semconv.ServiceName("my-go-service"),
    ))

    tp := sdktrace.NewTracerProvider(
        sdktrace.WithBatcher(exporter),
        sdktrace.WithResource(res),
    )
    otel.SetTracerProvider(tp)
    return tp, nil
}

func main() {
    ctx := context.Background()
    tp, err := initTracer(ctx)
    if err != nil {
        log.Fatal(err)
    }
    // Without this, buffered spans are dropped on exit.
    defer tp.Shutdown(ctx)

    mux := http.NewServeMux()
    mux.Handle("/transfers", otelhttp.NewHandler(transfersHandler(), "POST /transfers"))
    http.ListenAndServe(":8080", mux)
}

tracer := otel.Tracer("payments")

ctx, span := tracer.Start(ctx, "settle-transfer")
defer span.End()

span.SetAttributes(attribute.String("transfer.id", transferID))

if err := settle(ctx, transferID); err != nil {
    span.RecordError(err)
    span.SetStatus(codes.Error, err.Error())
}