Function initOTel

_examples/interceptor/cmd/custom_observability/main.go:115–158

initOTel initializes OpenTelemetry with stdout exporters for both tracing and metrics.

()

// initOTel initializes OpenTelemetry with stdout exporters for both tracing and metrics.
func initOTel() func() {
	ctx := context.Background()

	// Create resource with service info
	res, _ := resource.Merge(
		resource.Default(),
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceName("elasticsearch-example"),
		),
	)

	// Initialize trace exporter (stdout with pretty print)
	traceExporter, err := stdouttrace.New(stdouttrace.WithPrettyPrint())
	if err != nil {
		panic(err)
	}

	// Initialize tracer provider
	tracerProvider := sdktrace.NewTracerProvider(
		sdktrace.WithResource(res),
		sdktrace.WithSyncer(traceExporter), // Use Syncer for immediate output
	)
	otel.SetTracerProvider(tracerProvider)

	// Initialize metric exporter (stdout)
	metricExporter, err := stdoutmetric.New(stdoutmetric.WithPrettyPrint())
	if err != nil {
		panic(err)
	}

	// Initialize meter provider with periodic reader
	meterProvider := sdkmetric.NewMeterProvider(
		sdkmetric.WithResource(res),
		sdkmetric.WithReader(sdkmetric.NewPeriodicReader(metricExporter, sdkmetric.WithInterval(time.Second))),
	)
	otel.SetMeterProvider(meterProvider)

	// Return shutdown function
	return func() {
		_ = tracerProvider.Shutdown(ctx)
		_ = meterProvider.Shutdown(ctx)
	}
}

// LoggingInterceptor creates an interceptor that logs request and response details.
func LoggingInterceptor() elastictransport.InterceptorFunc {