feat: increase Kubernetes rate limits.

atombender · Oct 3, 2022 · 02f1b62 · 02f1b62
1 parent 3b291e7
commit 02f1b62
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/main.go b/main.go
@@ -119,19 +119,24 @@ func main() {
 	inclusionMatcher := buildMatcher(includePatterns, labelSelector, true)
 	exclusionMatcher := buildMatcher(excludePatterns, nil, false)
 
-	clientConfig := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(
+	clientConfig := clientcmd.NewInteractiveDeferredLoadingClientConfig(
 		&clientcmd.ClientConfigLoadingRules{
 			ExplicitPath: kubeconfigPath,
 		},
 		&clientcmd.ConfigOverrides{
 			CurrentContext: contextName,
-		})
+		},
+		nil)
 
 	config, err := clientConfig.ClientConfig()
 	if err != nil {
 		fail(err.Error())
 	}
 
+	// Set higher rate limits
+	config.QPS = 100
+	config.Burst = 100
+
 	clientset, err := kubernetes.NewForConfig(config)
 	if err != nil {
 		fail(err.Error())