Function TestIngesterRequests

modules/frontend/search_sharder_test.go:491–718

(t *testing.T)

}

func TestIngesterRequests(t *testing.T) {
	synctest.Test(t, func(t *testing.T) {
		nownow := time.Now()

		now := int(nownow.Unix())

		ago := func(d string) int {
			duration, err := time.ParseDuration(d)
			require.NoError(t, err)
			return int(nownow.Add(-duration).Unix())
		}
		tenMinutesAgo := int(nownow.Add(-10 * time.Minute).Unix())
		fifteenMinutesAgo := int(nownow.Add(-15 * time.Minute).Unix())
		twentyMinutesAgo := int(nownow.Add(-20 * time.Minute).Unix())

		tests := []struct {
			request           string
			queryBackendAfter time.Duration
			ingesterShards    int
			expectedURI       []string
			expectedError     error
		}{
			// start/end is outside queryBackendAfter
			{
				request:           "/?tags=foo%3Dbar&minDuration=10ms&maxDuration=30ms&limit=50&start=10&end=20",
				queryBackendAfter: 10 * time.Minute,
				expectedURI:       []string{},
				ingesterShards:    1,
			},
			// start/end is inside queryBackendAfter
			{
				request:           "/?tags=foo%3Dbar&minDuration=10ms&maxDuration=30ms&limit=50&start=" + strconv.Itoa(tenMinutesAgo) + "&end=" + strconv.Itoa(now),
				queryBackendAfter: 30 * time.Minute,
				expectedURI:       []string{"/querier?end=" + strconv.Itoa(now) + "&limit=50&maxDuration=30ms&minDuration=10ms&spss=3&start=" + strconv.Itoa(tenMinutesAgo) + "&tags=foo%3Dbar"},
				ingesterShards:    1,
			},
			// queryBackendAfter = 0 results in no ingester query
			{
				request:           "/?tags=foo%3Dbar&minDuration=10ms&maxDuration=30ms&limit=50&start=" + strconv.Itoa(tenMinutesAgo) + "&end=" + strconv.Itoa(now),
				queryBackendAfter: 0,
				expectedURI:       []string{},
				ingesterShards:    1,
			},
			// start/end = 20 - 10 mins ago - break across query backend after
			//  ingester start/End = 15 - 10 mins ago
			{
				request:           "/?tags=foo%3Dbar&minDuration=10ms&maxDuration=30ms&limit=50&start=" + strconv.Itoa(twentyMinutesAgo) + "&end=" + strconv.Itoa(tenMinutesAgo),
				queryBackendAfter: 15 * time.Minute,
				expectedURI:       []string{"/querier?end=" + strconv.Itoa(tenMinutesAgo) + "&limit=50&maxDuration=30ms&minDuration=10ms&spss=3&start=" + strconv.Itoa(fifteenMinutesAgo) + "&tags=foo%3Dbar"},
				ingesterShards:    1,
			},
			// start/end = 10 - now mins ago - break across query backend after
			//  ingester start/End = 10 - now mins ago
			//  backend start/End = 15 - 10 mins ago
			{
				request:           "/?tags=foo%3Dbar&minDuration=10ms&maxDuration=30ms&limit=50&start=" + strconv.Itoa(tenMinutesAgo) + "&end=" + strconv.Itoa(now),
				queryBackendAfter: 15 * time.Minute,
				expectedURI:       []string{"/querier?end=" + strconv.Itoa(now) + "&limit=50&maxDuration=30ms&minDuration=10ms&spss=3&start=" + strconv.Itoa(tenMinutesAgo) + "&tags=foo%3Dbar"},