forked from knative/serving
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Set 60 seconds as the timeout of route (knative#1667)
* Set a long default timeout for route * Only use one timeout DefaultRouteTimeout in Route
- Loading branch information
Zhimin Xiang
committed
Aug 2, 2018
1 parent
342cc20
commit 0405fc8
Showing
8 changed files
with
302 additions
and
11 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
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
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,126 @@ | ||
| // +build e2e | ||
|
|
||
| /* | ||
| Copyright 2018 The Knative 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 e2e | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net/http" | ||
| "strings" | ||
| "testing" | ||
|
|
||
| "github.com/knative/serving/test" | ||
| "github.com/knative/serving/test/spoof" | ||
|
|
||
| "go.uber.org/zap" | ||
|
|
||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| corev1 "k8s.io/api/core/v1" | ||
| ) | ||
|
|
||
| var ( | ||
| clients *test.Clients | ||
| logger *zap.SugaredLogger | ||
| ) | ||
| const ( | ||
| targetHostEnv = "TARGET_HOST" | ||
| helloworldResponse = "Hello World! How about some tasty noodles?" | ||
| ) | ||
|
|
||
| func createTargetHostEnvVars(routeName string, t *testing.T) []corev1.EnvVar { | ||
| helloWorldRoute, err := clients.Routes.Get(routeName, metav1.GetOptions{}) | ||
| if err != nil { | ||
| t.Fatalf("Failed to get Route of helloworld app: %v", err) | ||
| } | ||
| internalDomain := helloWorldRoute.Status.DomainInternal | ||
| logger.Infof("helloworld internal domain is %v.", internalDomain) | ||
| return []corev1.EnvVar{{ | ||
| Name: targetHostEnv, | ||
| Value: internalDomain, | ||
| }} | ||
| } | ||
|
|
||
| func sendRequest(resolvableDomain bool, domain string) (*spoof.Response, error) { | ||
| logger.Infof("The domain of request is %s.", domain) | ||
| client, err := spoof.New(clients.Kube, logger, domain, resolvableDomain) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| req, err := http.NewRequest(http.MethodGet, fmt.Sprintf("http://%s", domain), nil) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return client.Do(req) | ||
| } | ||
|
|
||
| // In this test, we set up two apps: helloworld and httpproxy. | ||
| // helloworld is a simple app that displays a plaintext string. | ||
| // httpproxy is a proxy that redirects request to internal service of helloworld app | ||
| // with FQDN {route}.{namespace}.svc.cluster.local. | ||
| // The expected result is that the request sent to httpproxy app is successfully redirected | ||
| // to helloworld app. | ||
| func TestServiceToServiceCall(t *testing.T) { | ||
| logger = test.GetContextLogger("TestServiceToServiceCall") | ||
| clients = Setup(t) | ||
|
|
||
| // Set up helloworld app. | ||
| helloWorldImagePath := strings.Join([]string{test.Flags.DockerRepo, "helloworld"}, "/") | ||
| logger.Infof("Creating a Route and Configuration for helloworld test app.") | ||
| helloWorldNames, err := CreateRouteAndConfig(clients, logger, helloWorldImagePath) | ||
| if err != nil { | ||
| t.Fatalf("Failed to create Route and Configuration: %v", err) | ||
| } | ||
| test.CleanupOnInterrupt(func() { TearDown(clients, helloWorldNames, logger) }, logger) | ||
| defer TearDown(clients, helloWorldNames, logger) | ||
| if err := test.WaitForRouteState(clients.Routes, helloWorldNames.Route, test.IsRouteReady, "RouteIsReady"); err != nil { | ||
| t.Fatalf("The Route %s was not marked as Ready to serve traffic: %v", helloWorldNames.Route, err) | ||
| } | ||
|
|
||
| // Set up httpproxy app. | ||
| httpProxyImagePath := strings.Join([]string{test.Flags.DockerRepo, "httpproxy"}, "/") | ||
| logger.Infof("Creating a Route and Configuration for httpproxy test app.") | ||
| envVars := createTargetHostEnvVars(helloWorldNames.Route, t) | ||
| httpProxyNames, err := CreateRouteAndConfigWithEnv(clients, logger, httpProxyImagePath, envVars) | ||
| if err != nil { | ||
| t.Fatalf("Failed to create Route and Configuration: %v", err) | ||
| } | ||
| test.CleanupOnInterrupt(func() { TearDown(clients, httpProxyNames, logger) }, logger) | ||
| defer TearDown(clients, httpProxyNames, logger) | ||
| if err := test.WaitForRouteState(clients.Routes, httpProxyNames.Route, test.IsRouteReady, "RouteIsReady"); err != nil { | ||
| t.Fatalf("The Route %s was not marked as Ready to serve traffic: %v", httpProxyNames.Route, err) | ||
| } | ||
| httpProxyRoute, err := clients.Routes.Get(httpProxyNames.Route, metav1.GetOptions{}) | ||
| if err != nil { | ||
| t.Fatalf("Failed to get Route %s: %v", httpProxyNames.Route, err) | ||
| } | ||
| if err = test.WaitForEndpointState(clients.Kube, logger, test.Flags.ResolvableDomain, httpProxyRoute.Status.Domain, test.MatchesAny, "HttpProxy"); err != nil { | ||
| t.Fatalf("Failed to start endpoint of httpproxy: %v", err) | ||
| } | ||
| logger.Info("httpproxy is ready.") | ||
|
|
||
|
|
||
| // Send request to httpproxy to trigger the http call from httpproxy Pod to internal service of helloworld app. | ||
| response, err := sendRequest(test.Flags.ResolvableDomain, httpProxyRoute.Status.Domain) | ||
| if err != nil { | ||
| t.Fatalf("Failed to send request to httpproxy. %v", err) | ||
| } | ||
| // We expect the response from httpproxy is equal to the response from htlloworld | ||
| if helloworldResponse != strings.TrimSpace(string(response.Body)) { | ||
| t.Fatalf("The httpproxy response %s is not equal to helloworld response %s.", string(response.Body), helloworldResponse) | ||
| } | ||
| } |
Oops, something went wrong.