Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
9c1e6926
Commit
9c1e6926
authored
Mar 14, 2016
by
k8s-merge-robot
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #22955 from lavalamp/fix-22238
Auto commit by PR queue bot
parents
a9c17c1f
1c54e411
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
6 additions
and
3 deletions
+6
-3
proxy.go
test/e2e/proxy.go
+6
-3
No files found.
test/e2e/proxy.go
View file @
9c1e6926
...
@@ -45,6 +45,9 @@ const (
...
@@ -45,6 +45,9 @@ const (
// Only print this many characters of the response (to keep the logs
// Only print this many characters of the response (to keep the logs
// legible).
// legible).
maxDisplayBodyLen
=
100
maxDisplayBodyLen
=
100
// We have seen one of these calls take just over 15 seconds, so putting this at 30.
proxyHTTPCallTimeout
=
30
*
time
.
Second
)
)
func
proxyContext
(
version
string
)
{
func
proxyContext
(
version
string
)
{
...
@@ -228,8 +231,8 @@ func proxyContext(version string) {
...
@@ -228,8 +231,8 @@ func proxyContext(version string) {
if
e
,
a
:=
val
,
string
(
body
);
e
!=
a
{
if
e
,
a
:=
val
,
string
(
body
);
e
!=
a
{
recordError
(
fmt
.
Sprintf
(
"%v: path %v: wanted %v, got %v"
,
i
,
path
,
e
,
a
))
recordError
(
fmt
.
Sprintf
(
"%v: path %v: wanted %v, got %v"
,
i
,
path
,
e
,
a
))
}
}
if
d
>
15
*
time
.
Second
{
if
d
>
proxyHTTPCallTimeout
{
recordError
(
fmt
.
Sprintf
(
"%v: path %v took %v >
15s"
,
i
,
path
,
d
))
recordError
(
fmt
.
Sprintf
(
"%v: path %v took %v >
%v"
,
i
,
path
,
d
,
proxyHTTPCallTimeout
))
}
}
}(
i
,
path
,
val
)
}(
i
,
path
,
val
)
// default QPS is 5
// default QPS is 5
...
@@ -295,7 +298,7 @@ func nodeProxyTest(f *Framework, prefix, nodeDest string) {
...
@@ -295,7 +298,7 @@ func nodeProxyTest(f *Framework, prefix, nodeDest string) {
}
else
{
}
else
{
Expect
(
err
)
.
NotTo
(
HaveOccurred
())
Expect
(
err
)
.
NotTo
(
HaveOccurred
())
Expect
(
status
)
.
To
(
Equal
(
http
.
StatusOK
))
Expect
(
status
)
.
To
(
Equal
(
http
.
StatusOK
))
Expect
(
d
)
.
To
(
BeNumerically
(
"<"
,
15
*
time
.
Second
))
Expect
(
d
)
.
To
(
BeNumerically
(
"<"
,
proxyHTTPCallTimeout
))
}
}
}
}
if
serviceUnavailableErrors
>
0
{
if
serviceUnavailableErrors
>
0
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment