increase client-go QPS and Burst

keikoproj · Jan 8, 2024 · 34c9500 · 34c9500
1 parent 1abacb1
commit 34c9500
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cmd/common.go b/cmd/common.go
@@ -41,6 +41,8 @@ func newKubernetesClient(localMode string) *kubernetes.Clientset {
 		if err != nil {
 			log.Fatalln("cannot load kubernetes config from InCluster")
 		}
+		config.QPS = 600
+		config.Burst = 2000
 	}
 	return kubernetes.NewForConfigOrDie(config)
 }

diff --git a/pkg/service/server.go b/pkg/service/server.go
@@ -115,9 +115,7 @@ func (mgr *Manager) Start() {
 	// process events from stream
 	for message := range mgr.eventStream {
 
-		startTime := time.Now()
 		event, err := mgr.newEvent(message, queueURL)
-		log.Debugf("create and validate new event took %v ms", time.Since(startTime).Milliseconds())
 		if err != nil {
 			mgr.RejectEvent(err, event)
 			continue