Skip to content

Commit 53810f4

Browse files
committed
update depracted workqueue functions
1 parent abbcd69 commit 53810f4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

controllers/git_controller.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ type GitController struct {
5555
client client.Client
5656
scheme *runtime.Scheme
5757
repositorySyncer *git.RepositorySyncer
58-
queue workqueue.RateLimitingInterface
58+
queue workqueue.TypedRateLimitingInterface[interface{}]
5959
wg sync.WaitGroup
6060
mtx sync.Mutex
6161
}
@@ -258,7 +258,7 @@ func (g *GitController) SetupWithManager(mgr ctrl.Manager) error {
258258

259259
g.scheme = mgr.GetScheme()
260260
g.client = mgr.GetClient()
261-
g.queue = workqueue.NewRateLimitingQueue(workqueue.NewItemExponentialFailureRateLimiter(30*time.Second, 600*time.Second))
261+
g.queue = workqueue.NewTypedRateLimitingQueue(workqueue.NewTypedItemExponentialFailureRateLimiter[interface{}](30*time.Second, 600*time.Second))
262262
g.ControllerOptions.Namespace = util.GetEnv("NAMESPACE", g.ControllerOptions.Namespace)
263263

264264
if err := mgr.Add(g); err != nil {

0 commit comments

Comments
 (0)