|
7 | 7 | "time" |
8 | 8 |
|
9 | 9 | kubeinformers "k8s.io/client-go/informers" |
| 10 | + "k8s.io/utils/clock" |
10 | 11 |
|
11 | 12 | kubemigratorclient "sigs.k8s.io/kube-storage-version-migrator/pkg/clients/clientset" |
12 | 13 | migrationv1alpha1informer "sigs.k8s.io/kube-storage-version-migrator/pkg/clients/informer" |
@@ -51,6 +52,7 @@ type authenticationOperatorInput struct { |
51 | 52 | apiregistrationv1Client apiregistrationclient.Interface |
52 | 53 | migrationClient kubemigratorclient.Interface |
53 | 54 | eventRecorder events.Recorder |
| 55 | + clock clock.PassiveClock |
54 | 56 |
|
55 | 57 | informerFactories []libraryapplyconfiguration.SimplifiedInformerFactory |
56 | 58 | } |
@@ -129,6 +131,7 @@ func CreateOperatorInputFromMOM(ctx context.Context, momInput libraryapplyconfig |
129 | 131 | apiregistrationv1Client: apiregistrationv1Client, |
130 | 132 | migrationClient: migrationClient, |
131 | 133 | eventRecorder: eventRecorder, |
| 134 | + clock: momInput.Clock, |
132 | 135 | informerFactories: []libraryapplyconfiguration.SimplifiedInformerFactory{ |
133 | 136 | libraryapplyconfiguration.DynamicInformerFactoryAdapter(dynamicInformers), // we don't share the dynamic informers, but we only want to start when requested |
134 | 137 | }, |
@@ -199,6 +202,7 @@ func CreateControllerInputFromControllerContext(ctx context.Context, controllerC |
199 | 202 | apiregistrationv1Client: apiregistrationv1Client, |
200 | 203 | migrationClient: migrationClient, |
201 | 204 | eventRecorder: eventRecorder, |
| 205 | + clock: clock.RealClock{}, |
202 | 206 | informerFactories: []libraryapplyconfiguration.SimplifiedInformerFactory{ |
203 | 207 | libraryapplyconfiguration.DynamicInformerFactoryAdapter(dynamicInformers), // we don't share the dynamic informers, but we only want to start when requested |
204 | 208 | }, |
|
0 commit comments