Add otlploghttp transform pkg

open-telemetry · Apr 10, 2024 · 647ee7e · 647ee7e
1 parent fb02927
commit 647ee7e
Show file tree

Hide file tree

Showing 5 changed files with 556 additions and 26 deletions.
diff --git a/exporters/otlp/otlplog/otlploghttp/client.go b/exporters/otlp/otlplog/otlploghttp/client.go
@@ -10,10 +10,10 @@ import (
 )
 
 type client struct {
-	uploadLogs func(context.Context, *logpb.ResourceLogs) error
+	uploadLogs func(context.Context, []*logpb.ResourceLogs) error
 }
 
-func (c *client) UploadLogs(ctx context.Context, rl *logpb.ResourceLogs) error {
+func (c *client) UploadLogs(ctx context.Context, rl []*logpb.ResourceLogs) error {
 	if c.uploadLogs != nil {
 		return c.uploadLogs(ctx, rl)
 	}

diff --git a/exporters/otlp/otlplog/otlploghttp/exporter.go b/exporters/otlp/otlplog/otlploghttp/exporter.go
@@ -5,7 +5,6 @@ package otlploghttp // import "go.opentelemetry.io/otel/exporters/otlp/otlplog/o
 
 import (
 	"context"
-	"errors"
 	"sync/atomic"
 
 	"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploghttp/internal/transform"
@@ -47,12 +46,11 @@ func (e *Exporter) Export(ctx context.Context, records []log.Record) error {
 	if e.stopped.Load() {
 		return nil
 	}
-	otlp, err := transformResourceLogs(records)
+	otlp := transformResourceLogs(records)
 	if otlp != nil {
-		// Best effort upload of transformable logs.
-		err = errors.Join(err, e.client.Load().UploadLogs(ctx, otlp))
+		return e.client.Load().UploadLogs(ctx, otlp)
 	}
-	return err
+	return nil
 }
 
 // Shutdown shuts down the Exporter. Calls to Export or ForceFlush will perform

diff --git a/exporters/otlp/otlplog/otlploghttp/exporter_test.go b/exporters/otlp/otlplog/otlploghttp/exporter_test.go
@@ -19,45 +19,34 @@ import (
 )
 
 func TestExporterExportErrors(t *testing.T) {
-	var (
-		errUpload = errors.New("upload")
-		errTForm  = errors.New("transform")
-	)
-
+	errUpload := errors.New("upload")
 	c := &client{
-		uploadLogs: func(context.Context, *logpb.ResourceLogs) error {
+		uploadLogs: func(context.Context, []*logpb.ResourceLogs) error {
 			return errUpload
 		},
 	}
 
-	orig := transformResourceLogs
-	transformResourceLogs = func(r []log.Record) (*logpb.ResourceLogs, error) {
-		return new(logpb.ResourceLogs), errTForm
-	}
-	t.Cleanup(func() { transformResourceLogs = orig })
-
 	e, err := newExporter(c, config{})
 	require.NoError(t, err, "New")
 
 	err = e.Export(context.Background(), make([]log.Record, 1))
 	assert.ErrorIs(t, err, errUpload)
-	assert.ErrorIs(t, err, errTForm)
 }
 
 func TestExporterExport(t *testing.T) {
 	var uploads int
 	c := &client{
-		uploadLogs: func(context.Context, *logpb.ResourceLogs) error {
+		uploadLogs: func(context.Context, []*logpb.ResourceLogs) error {
 			uploads++
 			return nil
 		},
 	}
 
 	orig := transformResourceLogs
 	var got []log.Record
-	transformResourceLogs = func(r []log.Record) (*logpb.ResourceLogs, error) {
+	transformResourceLogs = func(r []log.Record) []*logpb.ResourceLogs {
 		got = r
-		return new(logpb.ResourceLogs), nil
+		return make([]*logpb.ResourceLogs, 1)
 	}
 	t.Cleanup(func() { transformResourceLogs = orig })