fix(batchprocessor): prevent goroutine leak and data loss on shutdown
#14473Comparing
aditya4044656:fix/batch-processor-shutdown-goroutine-leak
(d40a9ed
) withmain
(77ffe4a
)0%
- Untouched
- 61
- Ignored
- 3
- Skipped
- 20
Unknown Walltime execution environment detected
Using the Walltime instrument on standard Hosted Runners will lead to inconsistent data. For the most accurate results, we recommend using CodSpeed Macro Runners: bare-metal machines fine-tuned for performance measurement consistency.Benchmarks
84 total
BenchmarkMultiBatchMetricProcessor2k
processor/batchprocessor/batch_processor_test.go+10%
142.4 ms129.1 ms
BenchmarkSplittingBasedOnByteSizeManyProfilesSlightlyAboveLimit
exporter/exporterhelper/xexporterhelper/profiles_batch_test.go+4%
87.2 ms84.2 ms
HTTP/2.0,_client_per_thread_(like_single_app)
config/confighttp/server_test.go::BenchmarkHttpRequest+4%
1.1 ms1.1 ms
BenchmarkSplittingBasedOnByteSizeHugeProfiles
exporter/exporterhelper/xexporterhelper/profiles_batch_test.go+3%
98.4 ms95.7 ms
md_trace_request/raw_bytes_338/compressed_bytes_256/compressor_gzip
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+3%
26.9 µs26.2 µs
HTTP/1.1,_client_per_thread_(like_single_app)
config/confighttp/server_test.go::BenchmarkHttpRequest+2%
1.1 ms1.1 ms
lg_log_request/raw_bytes_4850/compressed_bytes_217/compressor_zstd
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+2%
11.2 µs11 µs
BenchmarkHTTPProtoLogsSequential
receiver/otlpreceiver/otlp_benchmark_test.go+2%
5.2 ms5.1 ms
lg_trace_request/raw_bytes_7250/compressed_bytes_615/compressor_snappy
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+1%
2.4 µs2.4 µs
md_log_request/raw_bytes_242/compressed_bytes_260/compressor_snappy
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+1%
841 ns831 ns
lg_log_request/raw_bytes_4850/compressed_bytes_253/compressor_gzip
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+1%
37.3 µs36.9 µs
BenchmarkTracesMarshalJSON
pdata/ptrace/traces_test.go+1%
6 µs6 µs
md_log_request/raw_bytes_242/compressed_bytes_220/compressor_gzip
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+1%
22.5 µs22.3 µs
BenchmarkTracesUsage
pdata/ptrace/traces_test.go+1%
5.1 µs5 µs
BenchmarkLogsMarshalJSON
pdata/plog/logs_test.go+1%
3.8 µs3.8 µs
BenchmarkGRPCLogsSequential
receiver/otlpreceiver/otlp_benchmark_test.go+1%
6.3 ms6.3 ms
md_trace_request/raw_bytes_338/compressed_bytes_265/compressor_zstd
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors+1%
9 µs9 µs
lg_trace_request/raw_bytes_7250/compressed_bytes_269/compressor_zstd
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors0%
11.2 µs11.1 µs
BenchmarkLogsUsage
pdata/plog/logs_test.go0%
2.8 µs2.8 µs
BenchmarkPersistentQueue
exporter/exporterhelper/internal/queue/persistent_queue_test.go0%
204.2 µs203.5 µs
BenchmarkProfilesUsage
pdata/pprofile/profiles_test.go0%
3.6 µs3.5 µs
md_log_request/raw_bytes_242/compressed_bytes_210/compressor_zstd
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors0%
9.6 µs9.6 µs
BenchmarkTracesFromProto2k
pdata/ptrace/pb_test.go0%
227 µs226.4 µs
BenchmarkProfilesMarshalJSON
pdata/pprofile/profiles_test.go0%
4.3 µs4.3 µs
sm_trace_request/raw_bytes_240/compressed_bytes_211/compressor_zstd
config/configgrpc/configgrpc_benchmark_test.go::BenchmarkCompressors0%
8.1 µs8.1 µs
Commits
Click on a commit to change the comparison rangeBase
main
77ffe4a
+0.6%
fix(batchprocessor): prevent goroutine leak and data loss on shutdown
c58523b
3 days ago
by aditya4044656-8.52%
Add regression tests for shutdown race condition and context handling
18a36d9
2 days ago
by aditya4044656+8.09%
Fix lint errors in memory_queue_test.go
4d8bd60
2 days ago
by aditya4044656-0.44%
Fix comment alignment formatting
296673e
2 days ago
by aditya4044656+0.14%
Fix remaining lint issues in batch_processor_test.go
d40a9ed
2 days ago
by aditya4044656