fix data race

pkg/opentelemetry/init.go

@@ -12,6 +12,7 @@ import (
 	"go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc"
 	"go.opentelemetry.io/otel/exporters/otlp/otlptrace"
 	"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc"
+	"go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
 	"go.opentelemetry.io/otel/propagation"
 	sdkMetric "go.opentelemetry.io/otel/sdk/metric"
 	"go.opentelemetry.io/otel/sdk/resource"
@@ -106,10 +107,16 @@ func initGlobalTracer(ctx context.Context, res *resource.Resource, cfg Config) (
 		return nil, fmt.Errorf("create trace exporter: %w", err)
 	}
 
+	stdoutExporter, err := stdouttrace.New(stdouttrace.WithPrettyPrint())
+	if err != nil {
+		return nil, fmt.Errorf("create stdout trace exporter: %w", err)
+	}
+
 	tracerProvider := sdktrace.NewTracerProvider(
 		sdktrace.WithSampler(sdktrace.AlwaysSample()),
 		sdktrace.WithResource(res),
 		sdktrace.WithBatcher(exporter),
+		sdktrace.WithBatcher(stdoutExporter), // Stdout exporter
 	)
 
 	otel.SetTracerProvider(tracerProvider)

pkg/opentelemetry/otelhttpclient/http_transport.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"io"
 	"net/http"
+	"sync"
 	"time"
 
 	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
@@ -136,12 +137,15 @@ type bodyWrapper struct {
 
 	read int
 	err  error
+	mu   sync.Mutex
 }
 
 func (w *bodyWrapper) Read(b []byte) (int, error) {
 	n, err := w.ReadCloser.Read(b)
+	w.mu.Lock()
 	w.read += n
 	w.err = err
+	w.mu.Unlock()
 	return n, err
 }