Function TestWriteV2RequestFixture

storage/remote/codec_test.go:173–219

(t *testing.T)

}

func TestWriteV2RequestFixture(t *testing.T) {
	// Generate dynamically writeV2RequestFixture, reusing v1 fixture elements.
	st := writev2.NewSymbolTable()
	b := labels.NewScratchBuilder(0)
	labelRefs := st.SymbolizeLabels(writeRequestFixture.Timeseries[0].ToLabels(&b, nil), nil)
	exemplar1LabelRefs := st.SymbolizeLabels(writeRequestFixture.Timeseries[0].Exemplars[0].ToExemplar(&b, nil).Labels, nil)
	exemplar2LabelRefs := st.SymbolizeLabels(writeRequestFixture.Timeseries[1].Exemplars[0].ToExemplar(&b, nil).Labels, nil)
	expected := &writev2.Request{
		Timeseries: []writev2.TimeSeries{
			{
				LabelsRefs: labelRefs,
				Metadata: writev2.Metadata{
					Type:    writev2.Metadata_METRIC_TYPE_GAUGE,
					HelpRef: st.Symbolize(writeV2RequestSeries1Metadata.Help),
					UnitRef: st.Symbolize(writeV2RequestSeries1Metadata.Unit),
				},
				Samples:   []writev2.Sample{{Value: 1, Timestamp: 10, StartTimestamp: 1}},
				Exemplars: []writev2.Exemplar{{LabelsRefs: exemplar1LabelRefs, Value: 1, Timestamp: 10}},
				Histograms: []writev2.Histogram{
					writev2.FromIntHistogram(10, &testHistogram),
					writev2.FromFloatHistogram(20, testHistogram.ToFloat(nil)),
					writev2.FromIntHistogram(30, &testHistogramCustomBuckets),
					writev2.FromFloatHistogram(40, testHistogramCustomBuckets.ToFloat(nil)),
				},
			},
			{
				LabelsRefs: labelRefs,
				Metadata: writev2.Metadata{
					Type:    writev2.Metadata_METRIC_TYPE_COUNTER,
					HelpRef: st.Symbolize(writeV2RequestSeries2Metadata.Help),
					// No unit.
				},
				Samples:   []writev2.Sample{{Value: 2, Timestamp: 20}},
				Exemplars: []writev2.Exemplar{{LabelsRefs: exemplar2LabelRefs, Value: 2, Timestamp: 20}},
				Histograms: []writev2.Histogram{
					writev2.FromIntHistogram(50, &testHistogram),
					writev2.FromFloatHistogram(60, testHistogram.ToFloat(nil)),
					writev2.FromIntHistogram(70, &testHistogramCustomBuckets),
					writev2.FromFloatHistogram(80, testHistogramCustomBuckets.ToFloat(nil)),
				},
			},
		},
		Symbols: st.Symbols(),
	}
	// Check if it matches static writeV2RequestFixture.
	require.Equal(t, expected, writeV2RequestFixture)
}

func TestValidateLabelsAndMetricName(t *testing.T) {
	tests := []struct {