-
Notifications
You must be signed in to change notification settings - Fork 8.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1550 from aledbf/e2e-4
Add e2e tests - default backend
- Loading branch information
Showing
1,163 changed files
with
289,196 additions
and
14,174 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -28,3 +28,5 @@ Session.vim | |
| # coverage artifacts | ||
| .coverprofile | ||
| /gover.coverprofile | ||
|
|
||
| e2e-tests | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,58 @@ | ||
| /* | ||
| Copyright 2017 The Kubernetes Authors. | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package k8s | ||
|
|
||
| import ( | ||
| api "k8s.io/api/core/v1" | ||
| core "k8s.io/api/core/v1" | ||
| extensions "k8s.io/api/extensions/v1beta1" | ||
| k8sErrors "k8s.io/apimachinery/pkg/api/errors" | ||
| "k8s.io/client-go/kubernetes" | ||
| ) | ||
|
|
||
| func EnsureSecret(cl kubernetes.Interface, secret *api.Secret) (*api.Secret, error) { | ||
| s, err := cl.CoreV1().Secrets(secret.Namespace).Create(secret) | ||
| if err != nil { | ||
| if k8sErrors.IsAlreadyExists(err) { | ||
| return cl.CoreV1().Secrets(secret.Namespace).Update(secret) | ||
| } | ||
| return nil, err | ||
| } | ||
| return s, nil | ||
| } | ||
|
|
||
| func EnsureIngress(cl kubernetes.Interface, ingress *extensions.Ingress) (*extensions.Ingress, error) { | ||
| s, err := cl.ExtensionsV1beta1().Ingresses(ingress.Namespace).Update(ingress) | ||
| if err != nil { | ||
| if k8sErrors.IsNotFound(err) { | ||
| return cl.ExtensionsV1beta1().Ingresses(ingress.Namespace).Create(ingress) | ||
| } | ||
| return nil, err | ||
| } | ||
| return s, nil | ||
| } | ||
|
|
||
| func EnsureService(cl kubernetes.Interface, service *core.Service) (*core.Service, error) { | ||
| s, err := cl.CoreV1().Services(service.Namespace).Update(service) | ||
| if err != nil { | ||
| if k8sErrors.IsNotFound(err) { | ||
| return cl.CoreV1().Services(service.Namespace).Create(service) | ||
| } | ||
| return nil, err | ||
| } | ||
| return s, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
File renamed without changes.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,110 @@ | ||
| /* | ||
| Copyright 2017 The Kubernetes Authors. | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package defaultbackend | ||
|
|
||
| import ( | ||
| "crypto/tls" | ||
| "net/http" | ||
|
|
||
| . "github.com/onsi/ginkgo" | ||
| . "github.com/onsi/gomega" | ||
| "github.com/parnurzeal/gorequest" | ||
|
|
||
| "k8s.io/ingress-nginx/test/e2e/framework" | ||
| ) | ||
|
|
||
| const defaultBackend = "default backend - 404" | ||
|
|
||
| var _ = framework.IngressNginxDescribe("Default backend", func() { | ||
| f := framework.NewDefaultFramework("default-backend") | ||
|
|
||
| BeforeEach(func() { | ||
| }) | ||
|
|
||
| AfterEach(func() { | ||
| }) | ||
|
|
||
| It("should return 404 sending requests when only a default backend is running", func() { | ||
| httpURL, err := f.GetNginxURL(framework.HTTP) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
|
|
||
| httpsURL, err := f.GetNginxURL(framework.HTTPS) | ||
| Expect(err).NotTo(HaveOccurred()) | ||
|
|
||
| request := gorequest.New() | ||
|
|
||
| testCases := []struct { | ||
| Name string | ||
| Host string | ||
| Scheme framework.RequestScheme | ||
| Method string | ||
| Path string | ||
| Status int | ||
| }{ | ||
| {"basic HTTP GET request without host to path / should return 404", "", framework.HTTP, "GET", "/", 404}, | ||
| {"basic HTTP GET request without host to path /demo should return 404", "", framework.HTTP, "GET", "/demo", 404}, | ||
| {"basic HTTPS GET request without host to path / should return 404", "", framework.HTTPS, "GET", "/", 404}, | ||
| {"basic HTTPS GET request without host to path /demo should return 404", "", framework.HTTPS, "GET", "/demo", 404}, | ||
|
|
||
| {"basic HTTP POST request without host to path / should return 404", "", framework.HTTP, "POST", "/", 404}, | ||
| {"basic HTTP POST request without host to path /demo should return 404", "", framework.HTTP, "POST", "/demo", 404}, | ||
| {"basic HTTPS POST request without host to path / should return 404", "", framework.HTTPS, "POST", "/", 404}, | ||
| {"basic HTTPS POST request without host to path /demo should return 404", "", framework.HTTPS, "POST", "/demo", 404}, | ||
|
|
||
| {"basic HTTP GET request to host foo.bar.com and path / should return 404", " foo.bar.com", framework.HTTP, "GET", "/", 404}, | ||
| {"basic HTTP GET request to host foo.bar.com and path /demo should return 404", " foo.bar.com", framework.HTTP, "GET", "/demo", 404}, | ||
| {"basic HTTPS GET request to host foo.bar.com and path / should return 404", " foo.bar.com", framework.HTTPS, "GET", "/", 404}, | ||
| {"basic HTTPS GET request to host foo.bar.com and path /demo should return 404", " foo.bar.com", framework.HTTPS, "GET", "/demo", 404}, | ||
|
|
||
| {"basic HTTP POST request to host foo.bar.com and path / should return 404", " foo.bar.com", framework.HTTP, "POST", "/", 404}, | ||
| {"basic HTTP POST request to host foo.bar.com and path /demo should return 404", " foo.bar.com", framework.HTTP, "POST", "/demo", 404}, | ||
| {"basic HTTPS POST request to host foo.bar.com and path / should return 404", " foo.bar.com", framework.HTTPS, "POST", "/", 404}, | ||
| {"basic HTTPS POST request to host foo.bar.com and path /demo should return 404", " foo.bar.com", framework.HTTPS, "POST", "/demo", 404}, | ||
| } | ||
|
|
||
| for _, test := range testCases { | ||
| By(test.Name) | ||
| var errs []error | ||
| var cm *gorequest.SuperAgent | ||
|
|
||
| switch test.Scheme { | ||
| case framework.HTTP: | ||
| cm = request.CustomMethod(test.Method, httpURL) | ||
| break | ||
| case framework.HTTPS: | ||
| cm = request.CustomMethod(test.Method, httpsURL) | ||
| // the default backend uses a self generated certificate | ||
| cm.Transport = &http.Transport{ | ||
| TLSClientConfig: &tls.Config{ | ||
| InsecureSkipVerify: true, | ||
| }, | ||
| } | ||
| break | ||
| default: | ||
| Fail("Unexpected request scheme") | ||
| } | ||
|
|
||
| if test.Host != "" { | ||
| cm.Set("Host", test.Host) | ||
| } | ||
|
|
||
| resp, _, errs := cm.End() | ||
| Expect(len(errs)).Should(BeNumerically("==", 0)) | ||
| Expect(resp.StatusCode).Should(Equal(test.Status)) | ||
| } | ||
| }) | ||
| }) |
Oops, something went wrong.