Function newBenchStatsHandler

middleware/grpc_stats_bench_test.go:13–32

newBenchStatsHandler builds a handler with real Prometheus vecs (same as prod).

(b *testing.B)

// newBenchStatsHandler builds a handler with real Prometheus vecs (same as prod).
func newBenchStatsHandler(b *testing.B) stats.Handler {
	b.Helper()
	reg := prometheus.NewRegistry()

	received := promauto.With(reg).NewHistogramVec(prometheus.HistogramOpts{
		Name:    "bench_received_payload_bytes",
		Buckets: BodySizeBuckets,
	}, []string{"method", "route"})

	sent := promauto.With(reg).NewHistogramVec(prometheus.HistogramOpts{
		Name:    "bench_sent_payload_bytes",
		Buckets: BodySizeBuckets,
	}, []string{"method", "route"})

	inflight := promauto.With(reg).NewGaugeVec(prometheus.GaugeOpts{
		Name: "bench_inflight_requests",
	}, []string{"method", "route"})

	return NewStatsHandler(reg, received, sent, inflight, false)
}

// BenchmarkHandleRPC_InPayload measures the per-message hot path for incoming
// payloads on a streaming RPC (the dominant case in QueryStream).