Function TestPusherAppendable

pkg/ruler/compat_test.go:42–252

(t *testing.T)

}

func TestPusherAppendable(t *testing.T) {
	pusher := &fakePusher{}
	pa := NewPusherAppendable(pusher, "user-1", nil, prometheus.NewCounter(prometheus.CounterOpts{}), prometheus.NewCounter(prometheus.CounterOpts{}))

	lbls1 := cortexpb.FromLabelsToLabelAdapters(labels.FromMap(map[string]string{labels.MetricName: "foo_bar"}))
	lbls2 := cortexpb.FromLabelsToLabelAdapters(labels.FromMap(map[string]string{labels.MetricName: "ALERTS", labels.AlertName: "boop"}))

	testHistogram := tsdbutil.GenerateTestHistogram(1)
	testFloatHistogram := tsdbutil.GenerateTestFloatHistogram(2)
	testHistogramWithNaN := tsdbutil.GenerateTestHistogram(1)
	testFloatHistogramWithNaN := tsdbutil.GenerateTestFloatHistogram(1)
	testHistogramWithNaN.Sum = math.Float64frombits(value.StaleNaN)
	testFloatHistogramWithNaN.Sum = math.Float64frombits(value.StaleNaN)

	for _, tc := range []struct {
		name           string
		series         string
		value          float64
		histogram      *histogram.Histogram
		floatHistogram *histogram.FloatHistogram
		expectedReq    *cortexpb.WriteRequest
	}{
		{
			name:   "tenant, normal value",
			series: "foo_bar",
			value:  1.234,
			expectedReq: &cortexpb.WriteRequest{
				Timeseries: []cortexpb.PreallocTimeseries{
					{
						TimeSeries: &cortexpb.TimeSeries{
							Labels: lbls1,
							Samples: []cortexpb.Sample{
								{Value: 1.234, TimestampMs: 120_000},
							},
						},
					},
				},
				Source: cortexpb.RULE,
			},
		},
		{
			name:   "tenant, stale nan value",
			series: "foo_bar",
			value:  math.Float64frombits(value.StaleNaN),
			expectedReq: &cortexpb.WriteRequest{
				Timeseries: []cortexpb.PreallocTimeseries{
					{
						TimeSeries: &cortexpb.TimeSeries{
							Labels: lbls1,
							Samples: []cortexpb.Sample{
								{Value: math.Float64frombits(value.StaleNaN), TimestampMs: 120_000},
							},
						},
					},
				},
				Source: cortexpb.RULE,
			},
		},