Merge pull request #55897 from juanvallejo/jvallejo/expose-backoff-and-limiter-rest-request

Automatic merge from submit-queue (batch tested with PRs 55642, 55897, 55835, 55496, 55313). If you want to cherry-pick this change to another branch, please follow the instructions <a href="https://github.com/kubernetes/community/blob/master/contributors/devel/cherry-picks.md">here</a>. add rest/request backoffMgr and throttle setters **Release note**: ```release-note NONE ``` Allows modifications to be made to a request's rate-limiter and backoff manager from a `RequestOptions` func introduced in https://github.com/kubernetes/kubernetes/pull/55834 Depends on https://github.com/kubernetes/kubernetes/pull/55834 @enj @smarterclayton Kubernetes-commit: 17ff3caff47a824a3f3e9ab6b1aa94d8de87f00e
2025-06-26 07:02:01 +00:00 · 2017-11-18 10:46:32 -08:00 · 2017-11-18 10:46:32 -08:00 · 5b93d2bc5a
commit 5b93d2bc5a
parent a9b11fb1b4 f1ca0e5f1d
2 changed files with 714 additions and 696 deletions
--- a/Godeps/Godeps.json
+++ b/Godeps/Godeps.json
@ -480,215 +480,215 @@
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/equality",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/errors",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/meta",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/resource",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/testing",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/testing/fuzzer",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/api/testing/roundtrip",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apimachinery",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apimachinery/announced",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apimachinery/registered",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/fuzzer",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/internalversion",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1alpha1",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/conversion",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/conversion/queryparams",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/fields",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/labels",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/schema",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/json",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/protobuf",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/recognizer",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/streaming",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/versioning",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/selection",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/types",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/cache",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/clock",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/diff",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/errors",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/framer",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/httpstream",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/httpstream/spdy",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/intstr",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/json",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/mergepatch",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/net",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/remotecommand",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/runtime",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/sets",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/strategicpatch",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/validation",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/validation/field",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/wait",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/util/yaml",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/version",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/pkg/watch",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/json",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/netutil",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/reflect",
-			"Rev": "8d2e26d0cd42a060b527f3c91ebea1015959008e"
+      "Rev": "2de4f10de999ef5b857c77223949ff104db5e9dd"
    },
    {
      "ImportPath": "k8s.io/kube-openapi/pkg/common",
--- a/rest/request.go
+++ b/rest/request.go
@ -179,6 +179,24 @@ func (r *Request) Resource(resource string) *Request {
 	return r
 }

+// BackOff sets the request's backoff manager to the one specified,
+// or defaults to the stub implementation if nil is provided
+func (r *Request) BackOff(manager BackoffManager) *Request {
+	if manager == nil {
+		r.backoffMgr = &NoBackoff{}
+		return r
+	}
+
+	r.backoffMgr = manager
+	return r
+}
+
+// Throttle receives a rate-limiter and sets or replaces an existing request limiter
+func (r *Request) Throttle(limiter flowcontrol.RateLimiter) *Request {
+	r.throttle = limiter
+	return r
+}
+
 // SubResource sets a sub-resource path which can be multiple segments segment after the resource
 // name but before the suffix.
 func (r *Request) SubResource(subresources ...string) *Request {