[chore] Attempt to make benchmarks more resilient (#14227)

<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue.
Ex. Adding a feature - Explain what this achieves.-->
#### Description

Attempt to make the benchmarks more resilient by increasing their
walltimes to the microsecond range

<!-- Issue number if applicable -->
#### Link to tracking issue
Updates #14111

Author: mx-psi

config/confighttp/compressor_test.go

@@ -35,7 +35,7 @@ func BenchmarkCompression(b *testing.B) {
 			function: benchmarkCompressionNoConcurrency,
 		},
 	}
-	payload := make([]byte, 10<<20)
+	payload := make([]byte, 10<<22)
 	buffer := bytes.Buffer{}
 	buffer.Grow(len(payload))
 
@@ -55,38 +55,31 @@ func BenchmarkCompression(b *testing.B) {
 
 func benchmarkCompression(b *testing.B, _ configcompression.Type, buf *bytes.Buffer, payload []byte) {
 	// Concurrency Enabled
-
-	b.Run("compress", func(b *testing.B) {
-		stringReader := strings.NewReader(string(payload))
-		stringReadCloser := io.NopCloser(stringReader)
-		var enc io.Writer
-		b.ResetTimer()
-		b.ReportAllocs()
-		b.SetBytes(int64(len(payload)))
-		for b.Loop() {
-			enc, _ = zstd.NewWriter(nil, zstd.WithEncoderConcurrency(5))
-			enc.(writeCloserReset).Reset(buf)
-			_, copyErr := io.Copy(enc, stringReadCloser)
-			require.NoError(b, copyErr)
-		}
-	})
+	stringReader := strings.NewReader(string(payload))
+	stringReadCloser := io.NopCloser(stringReader)
+	var enc io.Writer
+	b.ResetTimer()
+	b.ReportAllocs()
+	b.SetBytes(int64(len(payload)))
+	for b.Loop() {
+		enc, _ = zstd.NewWriter(nil, zstd.WithEncoderConcurrency(5))
+		enc.(writeCloserReset).Reset(buf)
+		_, copyErr := io.Copy(enc, stringReadCloser)
+		require.NoError(b, copyErr)
+	}
 }
 
 func benchmarkCompressionNoConcurrency(b *testing.B, _ configcompression.Type, buf *bytes.Buffer, payload []byte) {
-	// Concurrency Disabled
-
-	b.Run("compress", func(b *testing.B) {
-		stringReader := strings.NewReader(string(payload))
-		stringReadCloser := io.NopCloser(stringReader)
-		var enc io.Writer
-		b.ResetTimer()
-		b.ReportAllocs()
-		b.SetBytes(int64(len(payload)))
-		for b.Loop() {
-			enc, _ = zstd.NewWriter(nil, zstd.WithEncoderConcurrency(1))
-			enc.(writeCloserReset).Reset(buf)
-			_, copyErr := io.Copy(enc, stringReadCloser)
-			require.NoError(b, copyErr)
-		}
-	})
+	stringReader := strings.NewReader(string(payload))
+	stringReadCloser := io.NopCloser(stringReader)
+	var enc io.Writer
+	b.ResetTimer()
+	b.ReportAllocs()
+	b.SetBytes(int64(len(payload)))
+	for b.Loop() {
+		enc, _ = zstd.NewWriter(nil, zstd.WithEncoderConcurrency(1))
+		enc.(writeCloserReset).Reset(buf)
+		_, copyErr := io.Copy(enc, stringReadCloser)
+		require.NoError(b, copyErr)
+	}
 }

processor/batchprocessor/batch_processor_test.go

@@ -716,7 +716,7 @@ func BenchmarkTraceSizeSpanCount(b *testing.B) {
 	}
 }
 
-func BenchmarkBatchMetricProcessor(b *testing.B) {
+func BenchmarkBatchMetricProcessor2k(b *testing.B) {
 	b.StopTimer()
 	cfg := &Config{
 		Timeout:       100 * time.Millisecond,
@@ -725,7 +725,7 @@ func BenchmarkBatchMetricProcessor(b *testing.B) {
 	runMetricsProcessorBenchmark(b, cfg)
 }
 
-func BenchmarkMultiBatchMetricProcessor(b *testing.B) {
+func BenchmarkMultiBatchMetricProcessor2k(b *testing.B) {
 	b.StopTimer()
 	cfg := &Config{
 		Timeout:       100 * time.Millisecond,
@@ -742,7 +742,7 @@ func runMetricsProcessorBenchmark(b *testing.B, cfg *Config) {
 	require.NoError(b, err)
 	require.NoError(b, metrics.Start(ctx, componenttest.NewNopHost()))
 
-	const metricsPerRequest = 1000
+	const metricsPerRequest = 150_000
 	b.StartTimer()
 	b.RunParallel(func(pb *testing.PB) {
 		for pb.Next() {