Exapose the rateLimiter

internal/commands/root/flag.go

@@ -47,7 +47,6 @@ func installFlags(flags *pflag.FlagSet, c *opts.Opts) {
 		"kubeAPIQPS is the QPS to use while talking with kubernetes apiserver")
 	flags.Int32Var(&c.KubeAPIBurst, "kube-api-burst", c.KubeAPIBurst,
 		"kubeAPIBurst is the burst to allow while talking with kubernetes apiserver")
-
 	flagset := flag.NewFlagSet("klog", flag.PanicOnError)
 	klog.InitFlags(flagset)
 	flagset.VisitAll(func(f *flag.Flag) {

internal/commands/root/root.go

@@ -196,6 +196,7 @@ func runRootCommandWithProviderAndClient(ctx context.Context, pInit provider.Ini
 		SecretInformer:    secretInformer,
 		ConfigMapInformer: configMapInformer,
 		ServiceInformer:   serviceInformer,
+		RateLimiter:       c.RateLimiter,
 	})
 	if err != nil {
 		return errors.Wrap(err, "error setting up pod controller")

opts/opts.go

@@ -23,6 +23,7 @@ import (
 	"github.com/mitchellh/go-homedir"
 	"github.com/pkg/errors"
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/client-go/util/workqueue"
 )
 
 // Defaults for root command options
@@ -93,6 +94,8 @@ type Opts struct {
 	KubeAPIQPS int32
 	// KubeAPIBurst is the burst to allow while talking with kubernetes apiserver
 	KubeAPIBurst int32
+	// RateLimiter defines the rate limit of work queue
+	RateLimiter workqueue.RateLimiter
 
 	Version string
 }
@@ -147,6 +150,7 @@ func setDefaults(o *Opts) {
 	o.KubeClusterDomain = DefaultKubeClusterDomain
 	o.StreamIdleTimeout = DefaultStreamIdleTimeout
 	o.StreamCreationTimeout = DefaultStreamCreationTimeout
+	o.RateLimiter = workqueue.DefaultControllerRateLimiter()
 }
 
 func getEnv(key, defaultValue string) string {