Drop usage of deprecated method NewNamedRateLimitingQueue

Signed-off-by: Davanum Srinivas <davanum@gmail.com>

Kubernetes-commit: c8b65422e582e4d6703b03cfea0aff0ac5e48ce2
This commit is contained in:
Davanum Srinivas
2023-10-17 14:46:13 -04:00
committed by Kubernetes Publisher
parent ee241d53d3
commit 362a7851c1
3 changed files with 41 additions and 21 deletions
+7 -1
View File
@@ -21,6 +21,8 @@ import (
"fmt"
"time"
"golang.org/x/time/rate"
appsv1 "k8s.io/api/apps/v1"
corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/errors"
@@ -103,6 +105,10 @@ func NewController(
eventBroadcaster.StartStructuredLogging(0)
eventBroadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: kubeclientset.CoreV1().Events("")})
recorder := eventBroadcaster.NewRecorder(scheme.Scheme, corev1.EventSource{Component: controllerAgentName})
ratelimiter := workqueue.NewMaxOfRateLimiter(
workqueue.NewItemExponentialFailureRateLimiter(5*time.Millisecond, 1000*time.Second),
&workqueue.BucketRateLimiter{Limiter: rate.NewLimiter(rate.Limit(50), 300)},
)
controller := &Controller{
kubeclientset: kubeclientset,
@@ -111,7 +117,7 @@ func NewController(
deploymentsSynced: deploymentInformer.Informer().HasSynced,
foosLister: fooInformer.Lister(),
foosSynced: fooInformer.Informer().HasSynced,
workqueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "Foos"),
workqueue: workqueue.NewRateLimitingQueue(ratelimiter),
recorder: recorder,
}