Function testNewScrapePool

scrape/scrape_test.go:99–126

(t *testing.T, appV2 bool)

}

func testNewScrapePool(t *testing.T, appV2 bool) {
	var (
		app = teststorage.NewAppendable()
		sa  = selectAppendable(app, appV2)
		cfg = &config.ScrapeConfig{
			MetricNameValidationScheme: model.UTF8Validation,
			MetricNameEscapingScheme:   model.AllowUTF8,
		}
		sp, err = newScrapePool(cfg, sa.V1(), sa.V2(), 0, nil, nil, &Options{}, newTestScrapeMetrics(t))
	)
	require.NoError(t, err)

	if appV2 {
		a, ok := sp.appendableV2.(*teststorage.Appendable)
		require.True(t, ok, "Failure to append.")
		require.Equal(t, app, a, "Wrong sample AppenderV2.")
		require.Equal(t, cfg, sp.config, "Wrong scrape config.")

		require.Nil(t, sp.appendable)
		return
	}
	a, ok := sp.appendable.(*teststorage.Appendable)
	require.True(t, ok, "Failure to append.")
	require.Equal(t, app, a, "Wrong sample appender.")
	require.Equal(t, cfg, sp.config, "Wrong scrape config.")

	require.Nil(t, sp.appendableV2)
}

func TestStorageHandlesOutOfOrderTimestamps(t *testing.T) {
	foreachAppendable(t, func(t *testing.T, appV2 bool) {