feat(output): Support OTLP metrics

generator/apache/apache_test.go

@@ -53,6 +53,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -289,6 +293,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkApacheGenerator(b *testing.B) {
 	logger := zaptest.NewLogger(b)
 	writer := &discardWriter{}

generator/apache_combined/apache_combined_test.go

@@ -53,6 +53,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -290,6 +294,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkApacheCombinedGenerator(b *testing.B) {
 	logger := zaptest.NewLogger(b)
 	writer := &discardWriter{}

generator/apache_error/apache_error_test.go

@@ -53,6 +53,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -296,6 +300,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkApacheErrorGenerator(b *testing.B) {
 	logger := zaptest.NewLogger(b)
 	writer := &discardWriter{}

generator/filegen/filegen_test.go

@@ -49,6 +49,10 @@ func (m *mockWriter) Write(ctx context.Context, record output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) Close(ctx context.Context) error {
 	return nil
 }

generator/json/json_test.go

@@ -62,6 +62,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -389,6 +393,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkGenerateDefaultLog(b *testing.B) {
 	b.ResetTimer()
 	for i := 0; i < b.N; i++ {

generator/nginx/nginx_test.go

@@ -53,6 +53,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -269,6 +273,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkNginxGenerator(b *testing.B) {
 	logger := zaptest.NewLogger(b)
 	writer := &discardWriter{}

generator/okta/okta_test.go

@@ -44,6 +44,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()

generator/paloalto/paloalto_test.go

@@ -52,6 +52,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()

generator/postgres/postgres_test.go

@@ -53,6 +53,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()
@@ -270,6 +274,10 @@ func (d *discardWriter) Write(ctx context.Context, data output.LogRecord) error
 	return nil
 }
 
+func (d *discardWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func BenchmarkPostgresGenerator(b *testing.B) {
 	logger := zaptest.NewLogger(b)
 	writer := &discardWriter{}

generator/winevt/winevt_test.go

@@ -33,6 +33,10 @@ func (m *mockWriter) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+func (m *mockWriter) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 func (m *mockWriter) getWrites() [][]byte {
 	m.mu.Lock()
 	defer m.mu.Unlock()

output/file/file.go

@@ -200,7 +200,11 @@ func (f *File) Write(ctx context.Context, data output.LogRecord) error {
 	}
 }
 
-// Stop gracefully stops workers and closes the writer
+// WriteMetric is not supported by the file output.
+func (f *File) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 // SupportedTelemetry returns the telemetry types this output supports.
 func (f *File) SupportedTelemetry() []telemetry.Type {
 	return []telemetry.Type{telemetry.Logs}

output/nop/nop.go

@@ -36,6 +36,11 @@ func (o *NopOutput) Write(ctx context.Context, data output.LogRecord) error {
 	return nil
 }
 
+// WriteMetric is not supported by the nop output.
+func (o *NopOutput) WriteMetric(_ context.Context, _ output.MetricRecord) error {
+	return output.ErrUnsupportedTelemetryType
+}
+
 // Stop performs no work
 func (o *NopOutput) Stop(ctx context.Context) error {
 	o.logger.Info("Stopping NOP output")