Function runPRW2HandleFromPool

pkg/util/push/push_test.go:238–247

runPRW2HandleFromPool simulates handlePRW2 using the sync.Pool

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

// runPRW2HandleFromPool simulates handlePRW2 using the sync.Pool
func runPRW2HandleFromPool(ctx context.Context, body []byte, contentLength int, overrides *validation.Overrides, userID string) error {
	req := cortexpb.PreallocWriteRequestV2FromPool()
	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
}

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