Function Test_convertV2RequestToV1

pkg/util/push/push_test.go:515–579

(t *testing.T)

}

func Test_convertV2RequestToV1(t *testing.T) {
	var v2Req cortexpb.PreallocWriteRequestV2

	fh := tsdbutil.GenerateTestFloatHistogram(1)
	ph := cortexpb.WrapHistogram(cortexpb.FloatHistogramToHistogramProto(4, fh))

	symbols := []string{"", "__name__", "test_metric", "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"}
	timeseries := []cortexpb.PreallocTimeseriesV2{
		{
			TimeSeriesV2: &cortexpb.TimeSeriesV2{
				LabelsRefs: []uint32{1, 2, 3, 4, 5, 6, 7, 8, 9, 10},
				Metadata: cortexpb.MetadataV2{
					Type: cortexpb.METRIC_TYPE_COUNTER,

					HelpRef: 15,
					UnitRef: 16,
				},
				Samples:   []cortexpb.Sample{{Value: 1, TimestampMs: 1}},
				Exemplars: []cortexpb.ExemplarV2{{LabelsRefs: []uint32{11, 12}, Value: 1, Timestamp: 1}},
			},
		},
		{
			TimeSeriesV2: &cortexpb.TimeSeriesV2{
				LabelsRefs: []uint32{1, 2, 3, 4, 5, 6, 7, 8, 9, 10},
				Samples:    []cortexpb.Sample{{Value: 2, TimestampMs: 2}},
			},
		},
		{
			TimeSeriesV2: &cortexpb.TimeSeriesV2{
				LabelsRefs: []uint32{1, 2, 3, 4, 5, 6, 7, 8, 9, 10},
				Samples:    []cortexpb.Sample{{Value: 3, TimestampMs: 3}},
			},
		},
		{
			TimeSeriesV2: &cortexpb.TimeSeriesV2{
				LabelsRefs: []uint32{1, 2, 3, 4, 5, 6, 7, 8, 9, 10},
				Histograms: []cortexpb.WrappedHistogram{ph, ph},
				Exemplars:  []cortexpb.ExemplarV2{{LabelsRefs: []uint32{11, 12}, Value: 1, Timestamp: 1}},
			},
		},
	}

	v2Req.Symbols = symbols
	v2Req.Timeseries = timeseries
	v1Req, err := convertV2RequestToV1(&v2Req, false)
	assert.NoError(t, err)
	expectedSamples := 3
	expectedExemplars := 2
	expectedHistograms := 2
	countSamples := 0
	countExemplars := 0
	countHistograms := 0

	for _, ts := range v1Req.Timeseries {
		countSamples += len(ts.Samples)
		countExemplars += len(ts.Exemplars)
		countHistograms += len(ts.Histograms)
	}