github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 09:22:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #121306 from dims/drop-usage-of-deprecated-method-NewNamedRateLimitingQueue

Browse Source 
[sample-controller] Drop usage of deprecated method NewNamedRateLimitingQueue
This commit is contained in:
Kubernetes Prow Robot 2023-10-26 08:34:30 +02:00 committed by GitHub
commit 2dc35c28bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
staging/src/k8s.io/sample-controller/controller.go
View File

@ -21,6 +21,8 @@ import (
"fmt" "fmt"
"time" "time"
"golang.org/x/time/rate"
appsv1 "k8s.io/api/apps/v1" appsv1 "k8s.io/api/apps/v1"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/errors"
@ -103,6 +105,10 @@ func NewController(
eventBroadcaster.StartStructuredLogging(0) eventBroadcaster.StartStructuredLogging(0)
eventBroadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: kubeclientset.CoreV1().Events("")}) eventBroadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: kubeclientset.CoreV1().Events("")})
recorder := eventBroadcaster.NewRecorder(scheme.Scheme, corev1.EventSource{Component: controllerAgentName}) 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{ controller := &Controller{
kubeclientset: kubeclientset, kubeclientset: kubeclientset,
@ -111,7 +117,7 @@ func NewController(
deploymentsSynced: deploymentInformer.Informer().HasSynced, deploymentsSynced: deploymentInformer.Informer().HasSynced,
foosLister: fooInformer.Lister(), foosLister: fooInformer.Lister(),
foosSynced: fooInformer.Informer().HasSynced, foosSynced: fooInformer.Informer().HasSynced,
workqueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "Foos"), workqueue: workqueue.NewRateLimitingQueue(ratelimiter),
recorder: recorder, recorder: recorder,
} }

2
staging/src/k8s.io/sample-controller/go.mod
View File

@ -5,6 +5,7 @@ module k8s.io/sample-controller
go 1.20 go 1.20
require ( require (
golang.org/x/time v0.3.0
k8s.io/api v0.0.0 k8s.io/api v0.0.0
k8s.io/apimachinery v0.0.0 k8s.io/apimachinery v0.0.0
k8s.io/client-go v0.0.0 k8s.io/client-go v0.0.0
@ -42,7 +43,6 @@ require (
golang.org/x/sys v0.13.0 // indirect golang.org/x/sys v0.13.0 // indirect
golang.org/x/term v0.13.0 // indirect golang.org/x/term v0.13.0 // indirect
golang.org/x/text v0.13.0 // indirect golang.org/x/text v0.13.0 // indirect
golang.org/x/time v0.3.0 // indirect
golang.org/x/tools v0.12.0 // indirect golang.org/x/tools v0.12.0 // indirect
google.golang.org/appengine v1.6.7 // indirect google.golang.org/appengine v1.6.7 // indirect
google.golang.org/protobuf v1.31.0 // indirect google.golang.org/protobuf v1.31.0 // indirect