Function TestScrapeLoopAppend_StartTimeSynthesis

scrape/scrape_test.go:1789–1917

(t *testing.T)

}

func TestScrapeLoopAppend_StartTimeSynthesis(t *testing.T) {
	ts := time.Now()

	requireSample := func(t *testing.T, s teststorage.Sample, name string, val float64, ts, st int64, isNaN bool) {
		t.Helper()
		require.Equal(t, name, s.L.Get(model.MetricNameLabel))
		require.Equal(t, ts, s.T)
		if isNaN {
			require.True(t, value.IsStaleNaN(s.V))
		} else {
			require.Equal(t, val, s.V)
		}
		require.Equal(t, st, s.ST)
	}

	s := teststorage.New(t)

	appTest := teststorage.NewAppendable().Then(s)
	sl, _ := newTestScrapeLoop(t, withAppendable(appTest, true), func(sl *scrapeLoop) {
		sl.synthesizeST = true
		sl.parseST = true
	})

	// First Scrape: anchor the start time, append is skipped.
	scrapeA := []byte(`# TYPE test_metric counter
test_metric 10
# TYPE test_gauge gauge
test_gauge 10
# EOF
`)
	app := sl.appender()
	_, _, _, err := app.append(scrapeA, "application/openmetrics-text", ts)
	require.NoError(t, err)
	require.NoError(t, app.Commit())

	// Gauge should have 1 point, Counter should be skipped.
	got := appTest.ResultSamples()
	require.Len(t, got, 1)
	requireSample(t, got[0], "test_gauge", 10, timestamp.FromTime(ts), 0, false)

	// Second Scrape: Counter should yield 1 point with delta = 5, and ST = ts.
	ts2 := ts.Add(time.Second)
	scrapeB := []byte(`# TYPE test_metric counter
test_metric 15
# TYPE test_gauge gauge
test_gauge 12
# EOF
`)
	app = sl.appender()
	_, _, _, err = app.append(scrapeB, "application/openmetrics-text", ts2)
	require.NoError(t, err)
	require.NoError(t, app.Commit())

	got = appTest.ResultSamples()

	require.Len(t, got, 3)
	requireSample(t, got[0], "test_gauge", 10, timestamp.FromTime(ts), 0, false)
	requireSample(t, got[1], "test_metric", 5, timestamp.FromTime(ts2), timestamp.FromTime(ts), false)