Function TestFormatQueryAPI

integration/format_query_api_test.go:19–126

(t *testing.T)

)

func TestFormatQueryAPI(t *testing.T) {
	s, err := e2e.NewScenario(networkName)
	require.NoError(t, err)
	defer s.Close()

	// Start dependencies.
	consul := e2edb.NewConsul()
	minio := e2edb.NewMinio(9000, bucketName)
	require.NoError(t, s.StartAndWaitReady(consul, minio))

	flags := mergeFlags(BlocksStorageFlags(), map[string]string{
		"-auth.enabled": "true",
	})

	// Start the query-frontend.
	queryFrontend := e2ecortex.NewQueryFrontend("query-frontend", flags, "")
	require.NoError(t, s.Start(queryFrontend))

	querier := e2ecortex.NewQuerier("querier", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), mergeFlags(flags, map[string]string{
		"-querier.frontend-address": queryFrontend.NetworkGRPCEndpoint(),
	}), "")
	require.NoError(t, s.StartAndWaitReady(querier))

	// Start querier without frontend.
	querierDirect := e2ecortex.NewQuerier("querier-direct", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), flags, "")
	require.NoError(t, s.StartAndWaitReady(querierDirect))

	require.NoError(t, s.WaitReady(queryFrontend))

	testCases := []struct {
		name           string
		query          string
		expectedResp   string
		expectError    bool
		method         string
		useOnlyQuerier bool
	}{
		{
			name:         "Valid query for GET method",
			query:        "foo/bar",
			expectedResp: "foo / bar",
			expectError:  false,
			method:       "GET",
		},
		{
			name:         "Valid query for POST method",
			query:        "foo/bar",
			expectedResp: "foo / bar",
			expectError:  false,
			method:       "POST",
		},
		{
			name:        "Invalid query for GET method",
			query:       "invalid_expression/",
			expectError: true,
			method:      "GET",
		},
		{