Use the new Marshaler in the OTLP HTTP exporter (#3433)

Updates #3104

Signed-off-by: Bogdan Drutu [email protected]

exporter/otlphttpexporter/otlp.go

@@ -38,6 +38,7 @@ import (
 	"go.opentelemetry.io/collector/consumer/pdata"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
 	"go.opentelemetry.io/collector/internal/middleware"
+	"go.opentelemetry.io/collector/internal/otlp"
 )
 
 type exporter struct {
@@ -50,6 +51,12 @@ type exporter struct {
 	logger     *zap.Logger
 }
 
+var (
+	tracesMarshaler  = otlp.NewProtobufTracesMarshaler()
+	metricsMarshaler = otlp.NewProtobufMetricsMarshaler()
+	logsMarshaler    = otlp.NewProtobufLogsMarshaler()
+)
+
 const (
 	headerRetryAfter         = "Retry-After"
 	maxHTTPResponseReadBytes = 64 * 1024
@@ -92,25 +99,25 @@ func (e *exporter) start(_ context.Context, host component.Host) error {
 	return nil
 }
 
-func (e *exporter) pushTraces(ctx context.Context, traces pdata.Traces) error {
-	request, err := traces.ToOtlpProtoBytes()
+func (e *exporter) pushTraces(ctx context.Context, td pdata.Traces) error {
+	request, err := tracesMarshaler.Marshal(td)
 	if err != nil {
 		return consumererror.Permanent(err)
 	}
 
 	return e.export(ctx, e.tracesURL, request)
 }
 
-func (e *exporter) pushMetrics(ctx context.Context, metrics pdata.Metrics) error {
-	request, err := metrics.ToOtlpProtoBytes()
+func (e *exporter) pushMetrics(ctx context.Context, md pdata.Metrics) error {
+	request, err := metricsMarshaler.Marshal(md)
 	if err != nil {
 		return consumererror.Permanent(err)
 	}
 	return e.export(ctx, e.metricsURL, request)
 }
 
-func (e *exporter) pushLogs(ctx context.Context, logs pdata.Logs) error {
-	request, err := logs.ToOtlpProtoBytes()
+func (e *exporter) pushLogs(ctx context.Context, ld pdata.Logs) error {
+	request, err := logsMarshaler.Marshal(ld)
 	if err != nil {
 		return consumererror.Permanent(err)
 	}