Function verifyOTLPWriteRequestHandler

pkg/util/push/otlp_test.go:1317–1331

(t *testing.T, expectSource cortexpb.SourceEnum)

}

func verifyOTLPWriteRequestHandler(t *testing.T, expectSource cortexpb.SourceEnum) func(ctx context.Context, request *cortexpb.WriteRequest) (response *cortexpb.WriteResponse, err error) {
	t.Helper()
	return func(ctx context.Context, request *cortexpb.WriteRequest) (response *cortexpb.WriteResponse, err error) {
		assert.Len(t, request.Timeseries, 13) // 1 (target_info) + 1 (counter) + 1 (gauge) + 7 (hist_bucket) + 2 (hist_sum, hist_count) + 1 (exponential histogram)
		// TODO: test more things
		assert.Equal(t, expectSource, request.Source)
		assert.False(t, request.SkipLabelNameValidation)
		for _, ts := range request.Timeseries {
			assert.NotEmpty(t, ts.Labels)
			// Make sure at least one of sample, exemplar or histogram is set.
			assert.True(t, len(ts.Samples) > 0 || len(ts.Exemplars) > 0 || len(ts.Histograms) > 0)
		}
		return &cortexpb.WriteResponse{}, nil
	}
}