otel_provider.go

package wool

//
//// SetupOTelSDK bootstraps the OpenTelemetry pipeline.
//// If it does not return an error, make sure to call shutdown for proper cleanup.
// func setupOTelSDK(ctx context.Context, serviceName, serviceVersion string) (shutdown func(context.Context) error, err error) {
//	var shutdownFuncs []func(context.Context) error
//
//	// shutdown calls cleanup functions registered via shutdownFuncs.
//	// The errors from the calls are joined.
//	// Each registered cleanup will be invoked once.
//	shutdown = func(ctx context.Context) error {
//		var err error
//		for _, fn := range shutdownFuncs {
//			err = errors.Join(err, fn(ctx))
//		}
//		shutdownFuncs = nil
//		return err
//	}
//
//	// handleErr calls shutdown for cleanup and makes sure that all errors are returned.
//	handleErr := func(inErr error) {
//		err = errors.Join(inErr, shutdown(ctx))
//	}
//
//	// Set up Resource.
//	res, err := newResource(serviceName, serviceVersion)
//	if err != nil {
//		handleErr(err)
//		return
//	}
//
//	// Set up propagator.
//	prop := newPropagator()
//	otel.SetTextMapPropagator(prop)
//
//	// Set up trace provider.
//	tracerProvider, err := newTraceProvider(res)
//	if err != nil {
//		handleErr(err)
//		return
//	}
//	shutdownFuncs = append(shutdownFuncs, tracerProvider.Shutdown)
//	otel.SetTracerProvider(tracerProvider)
//
//	// Set up meter provider.
//	meterProvider, err := newMeterProvider(res)
//	if err != nil {
//		handleErr(err)
//		return
//	}
//	shutdownFuncs = append(shutdownFuncs, meterProvider.Shutdown)
//	otel.SetMeterProvider(meterProvider)
//
//	return
// }
//
// func newResource(serviceName, serviceVersion string) (*resource.Resource, error) {
//	return resource.Merge(resource.Default(),
//		resource.NewWithAttributes(semconv.SchemaURL,
//			semconv.ServiceName(serviceName),
//			semconv.ServiceVersion(serviceVersion),
//		))
// }
//
// func newPropagator() propagation.TextMapPropagator {
//	return propagation.NewCompositeTextMapPropagator(
//		propagation.TraceContext{},
//		propagation.Baggage{},
//	)
// }
//
// func newTraceProvider(res *resource.Resource) (*trace.TracerProvider, error) {
//	traceExporter, err := stdouttrace.New(
//		stdouttrace.WithPrettyPrint())
//	if err != nil {
//		return nil, err
//	}
//
//	traceProvider := trace.NewTracerProvider(
//		trace.WithBatcher(traceExporter,
//			// Default is 5s. Set to 1s for demonstrative purposes.
//			trace.WithBatchTimeout(time.Second)),
//		trace.WithResource(res),
//	)
//	return traceProvider, nil
// }
//
// func newMeterProvider(res *resource.Resource) (*metric.MeterProvider, error) {
//	metricExporter, err := stdoutmetric.New()
//	if err != nil {
//		return nil, err
//	}
//
//	meterProvider := metric.NewMeterProvider(
//		metric.WithResource(res),
//		metric.WithReader(metric.NewPeriodicReader(metricExporter,
//			// Default is 1m. Set to 3s for demonstrative purposes.
//			metric.WithInterval(3*time.Second))),
//	)
//	return meterProvider, nil
// }