From 298f73a88fbcd963f3637540952080ac745df115 Mon Sep 17 00:00:00 2001 From: Niels de Vos Date: Tue, 30 Apr 2024 13:51:58 +0200 Subject: [PATCH] rebase: use new controller.Watch() API controller-runtime changed the format of the controller.Watch() function, so that needs adjusting. See-also: kubernetes-sigs/controller-runtime#2783 Signed-off-by: Niels de Vos --- internal/controller/persistentvolume/persistentvolume.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/internal/controller/persistentvolume/persistentvolume.go b/internal/controller/persistentvolume/persistentvolume.go index d83fb0a4f18a..69324378170b 100644 --- a/internal/controller/persistentvolume/persistentvolume.go +++ b/internal/controller/persistentvolume/persistentvolume.go @@ -82,7 +82,13 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error { } // Watch for changes to PersistentVolumes - err = c.Watch(source.Kind(mgr.GetCache(), &corev1.PersistentVolume{}), &handler.EnqueueRequestForObject{}) + err = c.Watch(source.Kind( + mgr.GetCache(), + &corev1.PersistentVolume{}, + handler.TypedEnqueueRequestForOwner[*corev1.PersistentVolume]( + mgr.GetScheme(), mgr.GetRESTMapper(), &corev1.PersistentVolume{}, + ), + )) if err != nil { return fmt.Errorf("failed to watch the changes: %w", err) }