Update to use a TypedRateLimiter (#74)

jonathan-innis · web-flow · commit 53716ab6d860 · 2024-09-11T09:14:15.000-07:00
diff --git a/reasonable/reasonable.go b/reasonable/reasonable.go
@@ -6,11 +6,12 @@ import (
 
 	"golang.org/x/time/rate"
 	"k8s.io/client-go/util/workqueue"
+	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 )
 
-func RateLimiter() workqueue.RateLimiter {
-	return workqueue.NewMaxOfRateLimiter(
-		workqueue.NewItemExponentialFailureRateLimiter(100*time.Millisecond, 1*time.Minute),
-		&workqueue.BucketRateLimiter{Limiter: rate.NewLimiter(rate.Limit(10), 100)},
+func RateLimiter() workqueue.TypedRateLimiter[reconcile.Request] {
+	return workqueue.NewTypedMaxOfRateLimiter[reconcile.Request](
+		workqueue.NewTypedItemExponentialFailureRateLimiter[reconcile.Request](100*time.Millisecond, 1*time.Minute),
+		&workqueue.TypedBucketRateLimiter[reconcile.Request]{Limiter: rate.NewLimiter(rate.Limit(10), 100)},
 	)
 }

Original file line number	Diff line number	Diff line change
`@@ -6,11 +6,12 @@ import (`
`6`	`6`
`7`	`7`	`"golang.org/x/time/rate"`
`8`	`8`	`"k8s.io/client-go/util/workqueue"`
	`9`	`+ "sigs.k8s.io/controller-runtime/pkg/reconcile"`
`9`	`10`	`)`
`10`	`11`
`11`		`-func RateLimiter() workqueue.RateLimiter {`
`12`		`- return workqueue.NewMaxOfRateLimiter(`
`13`		`- workqueue.NewItemExponentialFailureRateLimiter(100time.Millisecond, 1time.Minute),`
`14`		`- &workqueue.BucketRateLimiter{Limiter: rate.NewLimiter(rate.Limit(10), 100)},`
	`12`	`+func RateLimiter() workqueue.TypedRateLimiter[reconcile.Request] {`
	`13`	`+ return workqueue.NewTypedMaxOfRateLimiter[reconcile.Request](`
	`14`	`+ workqueue.NewTypedItemExponentialFailureRateLimiter[reconcile.Request](100time.Millisecond, 1time.Minute),`
	`15`	`+ &workqueue.TypedBucketRateLimiter[reconcile.Request]{Limiter: rate.NewLimiter(rate.Limit(10), 100)},`
`15`	`16`	`)`
`16`	`17`	`}`