Function Benchmark_Handler

pkg/util/push/push_test.go:168–208

(b *testing.B)

}

func Benchmark_Handler(b *testing.B) {
	var limits validation.Limits
	flagext.DefaultValues(&limits)
	overrides := validation.NewOverrides(limits, nil)

	mockHandler := func(context.Context, *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error) {
		// Nothing to do.
		return &cortexpb.WriteResponse{}, nil
	}
	testSeriesNums := []int{10, 100, 500, 1000}
	for _, seriesNum := range testSeriesNums {
		b.Run(fmt.Sprintf("PRW1 with %d series", seriesNum), func(b *testing.B) {
			handler := Handler(true, false, 1000000, overrides, nil, mockHandler, nil)
			req, err := createPRW1HTTPRequest(seriesNum)
			require.NoError(b, err)

			b.ReportAllocs()

			for b.Loop() {
				resp := httptest.NewRecorder()
				handler.ServeHTTP(resp, req)
				assert.Equal(b, http.StatusOK, resp.Code)
				req.Body.(*resetReader).Reset()
			}
		})
		b.Run(fmt.Sprintf("PRW2 with %d series", seriesNum), func(b *testing.B) {
			handler := Handler(true, false, 1000000, overrides, nil, mockHandler, nil)
			req, err := createPRW2HTTPRequest(seriesNum)
			require.NoError(b, err)

			b.ReportAllocs()

			for b.Loop() {
				resp := httptest.NewRecorder()
				handler.ServeHTTP(resp, req)
				assert.Equal(b, http.StatusNoContent, resp.Code)
				req.Body.(*resetReader).Reset()
			}
		})
	}
}

func Benchmark_convertV2RequestToV1(b *testing.B) {
	testSeriesNums := []int{100, 500, 1000}