Otlp http

internal/metrics/metrics.go

@@ -166,7 +166,7 @@ func GetExporter(ctx context.Context, cfg *config.MetricsConfig) (sdkmetric.Read
 			var exporter sdkmetric.Exporter
 
 			switch u.Scheme {
-			case "http", "https":
+			case "https":
 				exporter, err = otlpmetrichttp.New(ctx,
 					otlpmetrichttp.WithEndpoint(u.Host+u.Path),
 					otlpmetrichttp.WithHeaders(cfg.OTLP.Headers),
@@ -175,6 +175,16 @@ func GetExporter(ctx context.Context, cfg *config.MetricsConfig) (sdkmetric.Read
 					metricExpErr = fmt.Errorf("creating otlp metrics exporter: %w", err)
 					return
 				}
+			case "http":
+				exporter, err = otlpmetrichttp.New(ctx,
+					otlpmetrichttp.WithEndpoint(u.Host+u.Path),
+					otlpmetrichttp.WithHeaders(cfg.OTLP.Headers),
+					otlpmetrichttp.WithInsecure(),
+				)
+				if err != nil {
+					metricExpErr = fmt.Errorf("creating otlp metrics exporter: %w", err)
+					return
+				}
 			case "grpc":
 				exporter, err = otlpmetricgrpc.New(ctx,
 					otlpmetricgrpc.WithEndpoint(u.Host+u.Path),

internal/tracing/tracing.go

@@ -79,11 +79,17 @@ func GetExporter(ctx context.Context, cfg *config.TracingConfig) (tracesdk.SpanE
 
 			var client otlptrace.Client
 			switch u.Scheme {
-			case "http", "https":
+			case "https":
 				client = otlptracehttp.NewClient(
 					otlptracehttp.WithEndpoint(u.Host+u.Path),
 					otlptracehttp.WithHeaders(cfg.OTLP.Headers),
 				)
+			case "http":
+				client = otlptracehttp.NewClient(
+					otlptracehttp.WithEndpoint(u.Host+u.Path),
+					otlptracehttp.WithHeaders(cfg.OTLP.Headers),
+					otlptracehttp.WithInsecure(),
+				)
 			case "grpc":
 				// TODO: support additional configuration options
 				client = otlptracegrpc.NewClient(

internal/tracing/tracing_test.go

@@ -148,7 +148,6 @@ func TestGetExporter(t *testing.T) {
 			assert.NoError(t, err)
 			assert.NotNil(t, exp)
 			assert.NotNil(t, expFunc)
-
 		})
 	}
 }