Function checkQueries

integration/backward_compatibility_test.go:383–482

(
	t *testing.T,
	consul *e2e.HTTPService,
	expectedVector model.Vector,
	previousImage string,
	flagsForOldImage, flagsForNewImage map[string]string,
	now time.Time,
	s *e2e.Scenario,
	numIngesters int,
)

}

func checkQueries(
	t *testing.T,
	consul *e2e.HTTPService,
	expectedVector model.Vector,
	previousImage string,
	flagsForOldImage, flagsForNewImage map[string]string,
	now time.Time,
	s *e2e.Scenario,
	numIngesters int,
) {
	cases := map[string]struct {
		queryFrontendImage string
		queryFrontendFlags map[string]string
		querierImage       string
		querierFlags       map[string]string
		storeGatewayImage  string
		storeGatewayFlags  map[string]string
	}{
		"old query-frontend, new querier, old store-gateway": {
			queryFrontendImage: previousImage,
			queryFrontendFlags: flagsForOldImage,
			querierImage:       "",
			querierFlags:       flagsForNewImage,
			storeGatewayImage:  previousImage,
			storeGatewayFlags:  flagsForOldImage,
		},
		"new query-frontend, old querier, new store-gateway": {
			queryFrontendImage: "",
			queryFrontendFlags: flagsForNewImage,
			querierImage:       previousImage,
			querierFlags:       flagsForOldImage,
			storeGatewayImage:  "",
			storeGatewayFlags:  flagsForNewImage,
		},
	}

	for name, c := range cases {
		t.Run(name, func(t *testing.T) {
			// Start compactor to create the bucket index.
			compactor := e2ecortex.NewCompactor("compactor", consul.NetworkHTTPEndpoint(), c.storeGatewayFlags, c.storeGatewayImage)
			require.NoError(t, s.StartAndWaitReady(compactor))
			defer func() {
				require.NoError(t, s.Stop(compactor))
			}()

			// Start store gateway.
			storeGateway := e2ecortex.NewStoreGateway("store-gateway", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), c.storeGatewayFlags, c.storeGatewayImage)

			require.NoError(t, s.Start(storeGateway))
			defer func() {
				require.NoError(t, s.Stop(storeGateway))
			}()

			// Start query-frontend.
			queryFrontend := e2ecortex.NewQueryFrontend("query-frontend", c.queryFrontendFlags, c.queryFrontendImage)
			require.NoError(t, s.Start(queryFrontend))
			defer func() {
				require.NoError(t, s.Stop(queryFrontend))