set kube client qps and burst config if set

hashicorp · Feb 12, 2025 · 2c0c316 · 2c0c316
1 parent f10743b
commit 2c0c316
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/main.go b/main.go
@@ -356,6 +356,13 @@ func main() {
 	cfc.GlobalVaultAuthOptions = globalVaultAuthOptions
 
 	config := ctrl.GetConfigOrDie()
+	// set the Kube Client QPS and Burst config if they are set
+	if kubeClientQPS != 0 {
+		config.QPS = float32(kubeClientQPS)
+	}
+	if kubeClientBurst != 0 {
+		config.Burst = kubeClientBurst
+	}
 
 	defaultClient, err := client.NewWithWatch(config, client.Options{
 		Scheme: scheme,