Stdoutlog exporter metrics

CHANGELOG.md

@@ -15,6 +15,8 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
 - Greatly reduce the cost of recording metrics in `go.opentelemetry.io/otel/sdk/metric` using hashing for map keys. (#7175)
 - Add experimental observability for the prometheus exporter in `go.opentelemetry.io/otel/exporters/prometheus`.
   Check the `go.opentelemetry.io/otel/exporters/prometheus/internal/x` package documentation for more information. (#7345)
+- Add experimental observability log exporter metrics in `go.opentelemetry.io/otel/exporters/stdout/stdoutlog`.
+  Check the `go.opentelemetry.io/otel/exporters/stdout/stdoutlog/internal/x` package documentation for more information. (#7351)
 
 ### Fixed
 

exporters/stdout/stdoutlog/doc.go

@@ -9,4 +9,7 @@
 // format for OpenTelemetry that is supported with any stability or
 // compatibility guarantees. If these are needed features, please use the OTLP
 // exporter instead.
+//
+// See [go.opentelemetry.io/otel/exporters/stdout/stdoutlog/internal/x] for information about
+// the experimental features.
 package stdoutlog // import "go.opentelemetry.io/otel/exporters/stdout/stdoutlog"

exporters/stdout/stdoutlog/exporter.go

@@ -8,16 +8,30 @@ import (
 	"encoding/json"
 	"sync/atomic"
 
+	"go.opentelemetry.io/otel/exporters/stdout/stdoutlog/internal"
+	"go.opentelemetry.io/otel/exporters/stdout/stdoutlog/internal/counter"
+	"go.opentelemetry.io/otel/exporters/stdout/stdoutlog/internal/observ"
 	"go.opentelemetry.io/otel/sdk/log"
 )
 
+// otelComponentType is a name identifying the type of the OpenTelemetry component.
+const (
+	otelComponentType = "go.opentelemetry.io/otel/exporters/stdout/stdoutlog"
+
+	// Version is the current version of this instrumentation.
+	//
+	// This matches the version of the exporter.
+	Version = internal.Version
+)
+
 var _ log.Exporter = &Exporter{}
 
 // Exporter writes JSON-encoded log records to an [io.Writer] ([os.Stdout] by default).
 // Exporter must be created with [New].
 type Exporter struct {
-	encoder    atomic.Pointer[json.Encoder]
-	timestamps bool
+	encoder         atomic.Pointer[json.Encoder]
+	timestamps      bool
+	instrumentation *observ.Instrumentation
 }
 
 // New creates an [Exporter].
@@ -34,29 +48,50 @@ func New(options ...Option) (*Exporter, error) {
 	}
 	e.encoder.Store(enc)
 
+	exporterID := counter.NextExporterID()
+	inst, err := observ.NewInstrumentation(otelComponentType, exporterID)
+	if err != nil {
+		return nil, err
+	}
+	e.instrumentation = inst
+
 	return &e, nil
 }
 
 // Export exports log records to writer.
 func (e *Exporter) Export(ctx context.Context, records []log.Record) error {
+	if inst := e.instrumentation; inst != nil {
+		done := inst.ExportLogs(ctx, len(records))
+		exported, err := e.exportRecords(ctx, records)
+		done(exported, err)
+		return err
+	}
+
+	_, err := e.exportRecords(ctx, records)
+	return err
+}
+
+func (e *Exporter) exportRecords(ctx context.Context, records []log.Record) (int64, error) {
 	enc := e.encoder.Load()
 	if enc == nil {
-		return nil
+		return 0, nil
 	}
 
+	var exported int64
 	for _, record := range records {
 		// Honor context cancellation.
 		if err := ctx.Err(); err != nil {
-			return err
+			return exported, err
 		}
 
-		// Encode record, one by one.
 		recordJSON := e.newRecordJSON(record)
 		if err := enc.Encode(recordJSON); err != nil {
-			return err
+			return exported, err
 		}
+		exported++
 	}
-	return nil
+
+	return exported, nil
 }
 
 // Shutdown shuts down the Exporter.