Function testScrapeLoopOutOfBoundsTimeError

scrape/scrape_test.go:4395–4422

(t *testing.T, appV2 bool)

}

func testScrapeLoopOutOfBoundsTimeError(t *testing.T, appV2 bool) {
	sl, _ := newTestScrapeLoop(t, func(sl *scrapeLoop) {
		if appV2 {
			sl.appendableV2 = appendableV2Func(func(ctx context.Context) storage.AppenderV2 {
				return &timeLimitAppenderV2{
					AppenderV2: teststorage.NewAppendable().AppenderV2(ctx),
					maxTime:    timestamp.FromTime(time.Now().Add(10 * time.Minute)),
				}
			})
		} else {
			sl.appendable = appendableFunc(func(ctx context.Context) storage.Appender {
				return &timeLimitAppender{
					Appender: teststorage.NewAppendable().Appender(ctx),
					maxTime:  timestamp.FromTime(time.Now().Add(10 * time.Minute)),
				}
			})
		}
	})

	now := time.Now().Add(20 * time.Minute)
	app := sl.appender()
	total, added, seriesAdded, err := app.append([]byte("normal 1\n"), "text/plain", now)
	require.NoError(t, err)
	require.NoError(t, app.Commit())
	require.Equal(t, 1, total)
	require.Equal(t, 1, added)
	require.Equal(t, 0, seriesAdded)
}

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