Function benchmarkProduceRequestEncodeMetrics

produce_request_test.go:156–184

(b *testing.B, partitions int)

}

func benchmarkProduceRequestEncodeMetrics(b *testing.B, partitions int) {
	b.Helper()

	produceReq := &ProduceRequest{
		RequiredAcks: WaitForLocal,
		Timeout:      1_000,
	}
	for partition := range partitions {
		produceReq.AddMessage("bench.topic", int32(partition), &Message{
			Codec: CompressionNone,
			Value: []byte("payload"),
		})
	}

	req := &request{
		correlationID: 1,
		clientID:      "bench",
		body:          produceReq,
	}
	metricRegistry := NewConfig().MetricRegistry

	b.ReportAllocs()

	for b.Loop() {
		if _, err := encode(req, metricRegistry); err != nil {
			b.Fatal(err)
		}
	}
}

func BenchmarkProduceRequestEncodeMetrics1Partition(b *testing.B) {
	benchmarkProduceRequestEncodeMetrics(b, 1)