Add abitility to set QPS and Burst limits for api client

cmd/main.go

@@ -20,6 +20,8 @@ var (
 	outOfCluster   bool
 	version        string
 	config         spec.ControllerConfig
+	kubeQPS        int
+	kubeBurst      int
 )
 
 func mustParseDuration(d string) time.Duration {
@@ -35,6 +37,8 @@ func init() {
 	flag.BoolVar(&outOfCluster, "outofcluster", false, "Whether the operator runs in- our outside of the Kubernetes cluster.")
 	flag.BoolVar(&config.NoDatabaseAccess, "nodatabaseaccess", false, "Disable all access to the database from the operator side.")
 	flag.BoolVar(&config.NoTeamsAPI, "noteamsapi", false, "Disable all access to the teams API")
+	flag.IntVar(&kubeQPS, "kubeqps", 5, "Kubernetes api requests per second.")
+	flag.IntVar(&kubeBurst, "kubeburst", 10, "Kubernetes api requests burst limit.")
 	flag.Parse()
 
 	config.EnableJsonLogging = os.Getenv("ENABLE_JSON_LOGGING") == "true"
@@ -83,6 +87,9 @@ func main() {
 		log.Fatalf("couldn't get REST config: %v", err)
 	}
 
+	config.RestConfig.QPS = float32(kubeQPS)
+	config.RestConfig.Burst = kubeBurst
+
 	c := controller.NewController(&config, "")
 
 	c.Run(stop, wg)