Don't ratelimit the client

rancher · Aug 29, 2020 · 9588ca3 · 9588ca3
1 parent 2ec8aea
commit 9588ca3
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 2 deletions.
diff --git a/modules/agent/pkg/controllers/controllers.go b/modules/agent/pkg/controllers/controllers.go
@@ -4,9 +4,8 @@ import (
 	"context"
 	"time"
 
-	"github.com/rancher/fleet/modules/agent/pkg/controllers/cluster"
-
 	"github.com/rancher/fleet/modules/agent/pkg/controllers/bundledeployment"
+	"github.com/rancher/fleet/modules/agent/pkg/controllers/cluster"
 	"github.com/rancher/fleet/modules/agent/pkg/controllers/secret"
 	"github.com/rancher/fleet/modules/agent/pkg/deployer"
 	"github.com/rancher/fleet/modules/agent/pkg/trigger"
@@ -22,6 +21,7 @@ import (
 	"github.com/rancher/wrangler/pkg/generated/controllers/rbac"
 	rbaccontrollers "github.com/rancher/wrangler/pkg/generated/controllers/rbac/v1"
 	"github.com/rancher/wrangler/pkg/leader"
+	"github.com/rancher/wrangler/pkg/ratelimit"
 	"github.com/rancher/wrangler/pkg/start"
 	"github.com/sirupsen/logrus"
 	"k8s.io/apimachinery/pkg/api/meta"
@@ -175,6 +175,9 @@ func newContext(fleetNamespace, agentNamespace, clusterNamespace, clusterName st
 		return nil, err
 	}
 
+	client = rest.CopyConfig(client)
+	client.RateLimiter = ratelimit.None
+
 	k8s, err := kubernetes.NewForConfig(client)
 	if err != nil {
 		return nil, err

diff --git a/pkg/controllers/controllers.go b/pkg/controllers/controllers.go
@@ -29,6 +29,7 @@ import (
 	"github.com/rancher/wrangler/pkg/generated/controllers/rbac"
 	rbaccontrollers "github.com/rancher/wrangler/pkg/generated/controllers/rbac/v1"
 	"github.com/rancher/wrangler/pkg/leader"
+	"github.com/rancher/wrangler/pkg/ratelimit"
 	"github.com/rancher/wrangler/pkg/start"
 	"github.com/sirupsen/logrus"
 	corev1 "k8s.io/api/core/v1"
@@ -217,6 +218,7 @@ func newContext(cfg clientcmd.ClientConfig) (*appContext, error) {
 	if err != nil {
 		return nil, err
 	}
+	client.RateLimiter = ratelimit.None
 
 	core, err := core.NewFactoryFromConfig(client)
 	if err != nil {

diff --git a/pkg/helmdeployer/impersonate.go b/pkg/helmdeployer/impersonate.go
@@ -3,6 +3,7 @@ package helmdeployer
 import (
 	"fmt"
 
+	"github.com/rancher/wrangler/pkg/ratelimit"
 	apierror "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/cli-runtime/pkg/genericclioptions"
 	"k8s.io/client-go/rest"
@@ -39,6 +40,7 @@ func newImpersonatingGetter(namespace, name string, getter genericclioptions.RES
 	if err != nil {
 		return nil, err
 	}
+	restConfig.RateLimiter = ratelimit.None
 
 	return &impersonatingGetter{
 		RESTClientGetter: getter,