Add benchmark

Author: kisieland

processor/batchprocessor/batch_processor_test.go

@@ -17,6 +17,7 @@ package batchprocessor
 import (
 	"context"
 	"fmt"
+	"sync"
 	"testing"
 	"time"
 
@@ -504,6 +505,41 @@ func BenchmarkTraceSizeSpanCount(b *testing.B) {
 	}
 }
 
+func BenchmarkBatchMetricProcessor(b *testing.B) {
+	cfg := Config{
+		ProcessorSettings: config.NewProcessorSettings(config.NewID(typeStr)),
+		Timeout:           100 * time.Millisecond,
+		SendBatchSize:     2000,
+	}
+	ctx := context.Background()
+	sink := new(metricsSink)
+	createParams := component.ProcessorCreateParams{Logger: zap.NewNop()}
+	metricsPerRequest := 1000
+
+	batcher, err := newBatchMetricsProcessor(createParams, sink, &cfg, configtelemetry.LevelDetailed)
+	require.NoError(b, err)
+	require.NoError(b, batcher.Start(ctx, componenttest.NewNopHost()))
+
+	md := testdata.GenerateMetricsManyMetricsSameResource(metricsPerRequest)
+	for n := 0; n < b.N; n++ {
+		batcher.ConsumeMetrics(ctx, md.Clone())
+	}
+	require.NoError(b, batcher.Shutdown(ctx))
+	require.Equal(b, b.N*metricsPerRequest, sink.metricsCount)
+}
+
+type metricsSink struct {
+	mu           sync.Mutex
+	metricsCount int
+}
+
+func (sme *metricsSink) ConsumeMetrics(_ context.Context, md pdata.Metrics) error {
+	sme.mu.Lock()
+	defer sme.mu.Unlock()
+	sme.metricsCount += md.MetricCount()
+	return nil
+}
+
 func TestBatchLogProcessor_ReceivingData(t *testing.T) {
 	// Instantiate the batch processor with low config values to test data
 	// gets sent through the processor.