Function Benchmark_HandlePRW2_PoolVsScratch

pkg/util/push/push_test.go:264–291

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

(b *testing.B)

//   - pool:    req := cortexpb.PreallocWriteRequestV2FromPool() + defer ReuseWriteRequestV2(req)
//   - scratch: var req cortexpb.PreallocWriteRequestV2          + defer ReuseWriteRequestV2(&req)
func Benchmark_HandlePRW2_PoolVsScratch(b *testing.B) {
	var limits validation.Limits
	flagext.DefaultValues(&limits)
	overrides := validation.NewOverrides(limits, nil)

	userID := "bench-user"
	seriesNum := 100
	ctx := user.InjectOrgID(context.Background(), userID)

	for _, symCount := range []int{32, 128, 512, 2048, 4096} {
		body, contentLength := makeEncodedPRW2Body(b, seriesNum, symCount)
		name := fmt.Sprintf("symbols=%d", symCount)

		b.Run("pool/"+name, func(b *testing.B) {
			b.ReportAllocs()
			for b.Loop() {
				require.NoError(b, runPRW2HandleFromPool(ctx, body, contentLength, overrides, userID))
			}
		})

		b.Run("scratch/"+name, func(b *testing.B) {
			b.ReportAllocs()
			for b.Loop() {
				require.NoError(b, runPRW2HandleFromScratch(ctx, body, contentLength, overrides, userID))
			}
		})
	}
}

func Test_convertV2RequestToV1_WithEnableTypeAndUnitLabels(t *testing.T) {
	symbols := []string{"", "__name__", "test_metric1", "b", "c", "baz", "qux", "d", "e", "foo", "bar", "f", "g", "h", "i", "Test gauge for test purposes", "Maybe op/sec who knows (:", "Test counter for test purposes", "__type__", "exist type", "__unit__", "exist unit"}