@@ -62,7 +62,7 @@ func (r *PersistentVolumeReconciler) Reconcile(ctx context.Context, req ctrl.Req
62
62
63
63
// SetupWithManager sets up the controller with the Manager.
64
64
func (r * PersistentVolumeReconciler ) SetupWithManager (mgr ctrl.Manager , nodeName string ) error {
65
- ch := make (chan event.GenericEvent )
65
+ ch := make (chan event.TypedGenericEvent [ * corev1. PersistentVolume ] )
66
66
watcher := & persistentVolumeWatcher {
67
67
client : mgr .GetClient (),
68
68
ch : ch ,
@@ -73,7 +73,7 @@ func (r *PersistentVolumeReconciler) SetupWithManager(mgr ctrl.Manager, nodeName
73
73
if err != nil {
74
74
return err
75
75
}
76
- src := source .Channel (ch , & handler.EnqueueRequestForObject {})
76
+ src := source .Channel (ch , & handler.TypedEnqueueRequestForObject [ * corev1. PersistentVolume ] {})
77
77
78
78
pred := predicate.Funcs {
79
79
CreateFunc : func (event.CreateEvent ) bool { return true },
@@ -91,7 +91,7 @@ func (r *PersistentVolumeReconciler) SetupWithManager(mgr ctrl.Manager, nodeName
91
91
92
92
type persistentVolumeWatcher struct {
93
93
client client.Client
94
- ch chan <- event.GenericEvent
94
+ ch chan <- event.TypedGenericEvent [ * corev1. PersistentVolume ]
95
95
nodeName string
96
96
tick time.Duration
97
97
}
@@ -126,7 +126,7 @@ func (w *persistentVolumeWatcher) fireEvent(ctx context.Context) error {
126
126
if pv .Status .Phase != corev1 .VolumeReleased {
127
127
continue
128
128
}
129
- w .ch <- event.GenericEvent {
129
+ w .ch <- event.TypedGenericEvent [ * corev1. PersistentVolume ] {
130
130
Object : pv .DeepCopy (),
131
131
}
132
132
}
0 commit comments