Skip to content

K
k3s
Commit b77e1344 authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub
Browse files
Options

Merge pull request #34939 from wojtek-t/throttle_retried_requests

Automatic merge from submit-queue Throttle retried requests in client Fix #34938
parents 6ea0d05a 564fc0cc
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 0 deletions
pkg/client/restclient/request.go
View file @ b77e1344
...@@ -795,6 +795,12 @@ func (r *Request) request(fn func(*http.Request, *http.Response)) error { ...@@ -795,6 +795,12 @@ func (r *Request) request(fn func(*http.Request, *http.Response)) error {
req.Header = r.headers req.Header = r.headers
r.backoffMgr.Sleep(r.backoffMgr.CalculateBackoff(r.URL())) r.backoffMgr.Sleep(r.backoffMgr.CalculateBackoff(r.URL()))
if retries > 0 {
// We are retrying the request that we already send to apiserver
// at least once before.
// This request should also be throttled with the client-internal throttler.
r.tryThrottle()
}
resp, err := client.Do(req) resp, err := client.Do(req)
updateURLMetrics(r, resp, err) updateURLMetrics(r, resp, err)
if err != nil { if err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment