@@ -34,7 +34,6 @@ import (
34
34
"sigs.k8s.io/cluster-api-operator/internal/webhook"
35
35
clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
36
36
clusterctlv1 "sigs.k8s.io/cluster-api/cmd/clusterctl/api/v1alpha3"
37
- "sigs.k8s.io/cluster-api/controllers/remote"
38
37
"sigs.k8s.io/cluster-api/util/flags"
39
38
"sigs.k8s.io/cluster-api/version"
40
39
ctrl "sigs.k8s.io/controller-runtime"
@@ -228,39 +227,11 @@ func setupChecks(mgr ctrl.Manager) {
228
227
}
229
228
230
229
func setupReconcilers (mgr ctrl.Manager , watchConfigSecretChanges bool ) {
231
- secretCachingClient , err := client .New (mgr .GetConfig (), client.Options {
232
- HTTPClient : mgr .GetHTTPClient (),
233
- Cache : & client.CacheOptions {
234
- Reader : mgr .GetCache (),
235
- },
236
- })
237
- if err != nil {
238
- setupLog .Error (err , "unable to create secret caching client" )
239
- os .Exit (1 )
240
- }
241
- // Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
242
- // requiring a connection to a remote cluster
243
- tracker , err := remote .NewClusterCacheTracker (
244
- mgr ,
245
- remote.ClusterCacheTrackerOptions {
246
- SecretCachingClient : secretCachingClient ,
247
- ControllerName : "cluster-api-operator-controller" ,
248
- Log : & ctrl .Log ,
249
- ClientQPS : clusterCacheTrackerClientQPS ,
250
- ClientBurst : clusterCacheTrackerClientBurst ,
251
- },
252
- )
253
- if err != nil {
254
- setupLog .Error (err , "Unable to create cluster cache tracker" )
255
- os .Exit (1 )
256
- }
257
-
258
230
if err := (& providercontroller.GenericProviderReconciler {
259
231
Provider : & operatorv1.CoreProvider {},
260
232
ProviderList : & operatorv1.CoreProviderList {},
261
233
Client : mgr .GetClient (),
262
234
Config : mgr .GetConfig (),
263
- Tracker : tracker ,
264
235
WatchConfigSecretChanges : watchConfigSecretChanges ,
265
236
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
266
237
setupLog .Error (err , "unable to create controller" , "controller" , "CoreProvider" )
@@ -272,7 +243,6 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
272
243
ProviderList : & operatorv1.InfrastructureProviderList {},
273
244
Client : mgr .GetClient (),
274
245
Config : mgr .GetConfig (),
275
- Tracker : tracker ,
276
246
WatchConfigSecretChanges : watchConfigSecretChanges ,
277
247
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
278
248
setupLog .Error (err , "unable to create controller" , "controller" , "InfrastructureProvider" )
@@ -284,7 +254,6 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
284
254
ProviderList : & operatorv1.BootstrapProviderList {},
285
255
Client : mgr .GetClient (),
286
256
Config : mgr .GetConfig (),
287
- Tracker : tracker ,
288
257
WatchConfigSecretChanges : watchConfigSecretChanges ,
289
258
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
290
259
setupLog .Error (err , "unable to create controller" , "controller" , "BootstrapProvider" )
@@ -296,7 +265,6 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
296
265
ProviderList : & operatorv1.ControlPlaneProviderList {},
297
266
Client : mgr .GetClient (),
298
267
Config : mgr .GetConfig (),
299
- Tracker : tracker ,
300
268
WatchConfigSecretChanges : watchConfigSecretChanges ,
301
269
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
302
270
setupLog .Error (err , "unable to create controller" , "controller" , "ControlPlaneProvider" )
@@ -308,7 +276,6 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
308
276
ProviderList : & operatorv1.AddonProviderList {},
309
277
Client : mgr .GetClient (),
310
278
Config : mgr .GetConfig (),
311
- Tracker : tracker ,
312
279
WatchConfigSecretChanges : watchConfigSecretChanges ,
313
280
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
314
281
setupLog .Error (err , "unable to create controller" , "controller" , "AddonProvider" )
@@ -320,7 +287,6 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
320
287
ProviderList : & operatorv1.IPAMProviderList {},
321
288
Client : mgr .GetClient (),
322
289
Config : mgr .GetConfig (),
323
- Tracker : tracker ,
324
290
WatchConfigSecretChanges : watchConfigSecretChanges ,
325
291
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
326
292
setupLog .Error (err , "unable to create controller" , "controller" , "IPAMProvider" )
@@ -332,16 +298,14 @@ func setupReconcilers(mgr ctrl.Manager, watchConfigSecretChanges bool) {
332
298
ProviderList : & operatorv1.RuntimeExtensionProviderList {},
333
299
Client : mgr .GetClient (),
334
300
Config : mgr .GetConfig (),
335
- Tracker : tracker ,
336
301
WatchConfigSecretChanges : watchConfigSecretChanges ,
337
302
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
338
303
setupLog .Error (err , "unable to create controller" , "controller" , "RuntimeExtensionProvider" )
339
304
os .Exit (1 )
340
305
}
341
306
342
307
if err := (& healtchcheckcontroller.ProviderHealthCheckReconciler {
343
- Client : mgr .GetClient (),
344
- Tracker : tracker ,
308
+ Client : mgr .GetClient (),
345
309
}).SetupWithManager (mgr , concurrency (concurrencyNumber )); err != nil {
346
310
setupLog .Error (err , "unable to create controller" , "controller" , "Healthcheck" )
347
311
os .Exit (1 )
0 commit comments