From 165b498a4bfeca58e5db7bc8a1a2bccdb6275f8c Mon Sep 17 00:00:00 2001 From: Enxebre Date: Wed, 30 Oct 2019 11:41:31 +0100 Subject: [PATCH] UPSTREAM: : Revert "Adding config for event filtering" This reverts commit 6601bf0598140884ed06d37123da6d1c310a45fa. See https://github.com/kubernetes/autoscaler/issues/2495 --- .../utils/kubernetes/factory.go | 49 ++----------------- 1 file changed, 3 insertions(+), 46 deletions(-) diff --git a/cluster-autoscaler/utils/kubernetes/factory.go b/cluster-autoscaler/utils/kubernetes/factory.go index 77c245cdd9ee..a48e8e0f3cc9 100644 --- a/cluster-autoscaler/utils/kubernetes/factory.go +++ b/cluster-autoscaler/utils/kubernetes/factory.go @@ -25,22 +25,13 @@ import ( "k8s.io/client-go/kubernetes/scheme" v1core "k8s.io/client-go/kubernetes/typed/core/v1" kube_record "k8s.io/client-go/tools/record" -) - -const ( - // Rate of refill for the event spam filter in client go - // 1 per event key per 5 minutes. - defaultQPS = 1. / 300. - // Number of events allowed per event key before rate limiting is triggered - // Has to greater than or equal to 1. - defaultBurstSize = 1 - // Number of distinct event keys in the rate limiting cache. - defaultLRUCache = 8192 + klog "k8s.io/klog/v2" ) // CreateEventRecorder creates an event recorder to send custom events to Kubernetes to be recorded for targeted Kubernetes objects func CreateEventRecorder(kubeClient clientset.Interface) kube_record.EventRecorder { - eventBroadcaster := kube_record.NewBroadcasterWithCorrelatorOptions(getCorrelationOptions()) + eventBroadcaster := kube_record.NewBroadcaster() + eventBroadcaster.StartLogging(klog.V(4).Infof) if _, isfake := kubeClient.(*fake.Clientset); !isfake { actualSink := &v1core.EventSinkImpl{Interface: v1core.New(kubeClient.CoreV1().RESTClient()).Events("")} // EventBroadcaster has a StartLogging() method but the throttling options from getCorrelationOptions() get applied only to @@ -53,37 +44,3 @@ func CreateEventRecorder(kubeClient clientset.Interface) kube_record.EventRecord } return eventBroadcaster.NewRecorder(scheme.Scheme, clientv1.EventSource{Component: "cluster-autoscaler"}) } - -func getCorrelationOptions() kube_record.CorrelatorOptions { - return kube_record.CorrelatorOptions{ - QPS: defaultQPS, - BurstSize: defaultBurstSize, - LRUCacheSize: defaultLRUCache, - SpamKeyFunc: getCustomSpamKeyFunc(), - } -} - -// getCustomSpamKeyFunc returns EventSpamKeyFunc to be used by EventBroadcaster. -// By default only defaultBurstSize events are allowed to be sent per each -// event.Source-event.InvolvedObject combination. We want to emit defaultBurstSize events per each -// Reason-Source-InvolvedObject combination and for cluster-autoscaler-status ConfigMap we -// want to emit all of the events, thus we provide custom SpamKeyFunc -func getCustomSpamKeyFunc() kube_record.EventSpamKeyFunc { - return func(event *clientv1.Event) string { - elementsToJoin := []string{ - event.Reason, - event.Source.Component, - event.Source.Host, - event.InvolvedObject.Kind, - event.InvolvedObject.Namespace, - event.InvolvedObject.Name, - string(event.InvolvedObject.UID), - event.InvolvedObject.APIVersion, - } - // In case of cluster-autoscaler-status config map we want to emit all of the events, so we use event.Message as a key. - if event.InvolvedObject.Name == "cluster-autoscaler-status" && event.InvolvedObject.Namespace == "kube-system" && event.InvolvedObject.Kind == "ConfigMap" { - elementsToJoin = []string{event.Message} - } - return strings.Join(elementsToJoin, "") - } -}