diff --git a/cmd/kyverno/main.go b/cmd/kyverno/main.go index 2f59d073db..27c4f5cbe0 100644 --- a/cmd/kyverno/main.go +++ b/cmd/kyverno/main.go @@ -323,7 +323,7 @@ func main() { go rWebhookWatcher.Run(stopCh) go configData.Run(stopCh) go policyCtrl.Run(3, stopCh) - go eventGenerator.Run(1, stopCh) + go eventGenerator.Run(3, stopCh) go grc.Run(1, stopCh) go grcc.Run(1, stopCh) go pvgen.Run(1, stopCh) diff --git a/pkg/event/controller.go b/pkg/event/controller.go index 8dd35cfdf2..b032c14af2 100644 --- a/pkg/event/controller.go +++ b/pkg/event/controller.go @@ -1,8 +1,6 @@ package event import ( - "time" - "github.com/go-logr/logr" "github.com/nirmata/kyverno/pkg/client/clientset/versioned/scheme" @@ -61,7 +59,7 @@ func NewEventGenerator(client *client.Client, pInformer kyvernoinformer.ClusterP } func rateLimiter() workqueue.RateLimiter { - return workqueue.NewItemExponentialFailureRateLimiter(1*time.Second, 1000*time.Second) + return workqueue.DefaultItemBasedRateLimiter() } func initRecorder(client *client.Client, eventSource Source, log logr.Logger) record.EventRecorder {