Function runPRW2HandleFromScratch

pkg/util/push/push_test.go:250–259

runPRW2HandleFromScratch simulates handlePRW2 without using the sync.Pool.

(ctx context.Context, body []byte, contentLength int, overrides *validation.Overrides, userID string)

// runPRW2HandleFromScratch simulates handlePRW2 without using the sync.Pool.
func runPRW2HandleFromScratch(ctx context.Context, body []byte, contentLength int, overrides *validation.Overrides, userID string) error {
	var req cortexpb.PreallocWriteRequestV2
	defer cortexpb.ReuseWriteRequestV2(&req)

	if err := util.ParseProtoReader(ctx, bytes.NewReader(body), contentLength, benchMaxRecvMsgSize, &req, util.RawSnappy); err != nil {
		return err
	}
	_, err := convertV2RequestToV1(&req, overrides.EnableTypeAndUnitLabels(userID))
	return err
}

// Benchmark_HandlePRW2_PoolVsScratch compares two allocation strategies for the PRW2 parse path.
//   - pool:    req := cortexpb.PreallocWriteRequestV2FromPool() + defer ReuseWriteRequestV2(req)