✨ Add flags for configuring rate limits

Our controller have built-in rate limits. It throttles itself
if it hits this limit. So far it has not been possible to configure
these limits. This commit adds flags to the controller for setting both
the QPS and the burst for the rate limits. The default remains the same
as before (20 QPS, 30 burst).

Signed-off-by: Tobias Giese <[email protected]>
Co-Authored-by: Lennart Jern <[email protected]>

Author: tobiasgiese

main.go

@@ -69,6 +69,8 @@ var (
 	openStackClusterConcurrency int
 	openStackMachineConcurrency int
 	syncPeriod                  time.Duration
+	restConfigQPS               float32
+	restConfigBurst             int
 	webhookPort                 int
 	webhookCertDir              string
 	healthAddr                  string
@@ -128,6 +130,12 @@ func InitFlags(fs *pflag.FlagSet) {
 	fs.DurationVar(&syncPeriod, "sync-period", 10*time.Minute,
 		"The minimum interval at which watched resources are reconciled (e.g. 15m)")
 
+	fs.Float32Var(&restConfigQPS, "kube-api-qps", 20,
+		"Maximum queries per second from the controller client to the Kubernetes API server. Defaults to 20")
+
+	fs.IntVar(&restConfigBurst, "kube-api-burst", 30,
+		"Maximum number of queries that should be allowed in one burst from the controller client to the Kubernetes API server. Default 30")
+
 	fs.IntVar(&webhookPort, "webhook-port", 9443,
 		"Webhook Server port")
 
@@ -181,6 +189,8 @@ func main() {
 	if err != nil {
 		setupLog.Error(err, "unable to get kubeconfig")
 	}
+	cfg.QPS = restConfigQPS
+	cfg.Burst = restConfigBurst
 
 	var caCerts []byte
 	if caCertsPath != "" {