@@ -41,6 +41,7 @@ import (
41
41
clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
42
42
"sigs.k8s.io/cluster-api/api/v1beta1/index"
43
43
"sigs.k8s.io/cluster-api/controllers/remote"
44
+ machinecontroller "sigs.k8s.io/cluster-api/internal/controllers/machine"
44
45
machinesetcontroller "sigs.k8s.io/cluster-api/internal/controllers/machineset"
45
46
"sigs.k8s.io/cluster-api/internal/test/envtest"
46
47
)
@@ -100,20 +101,28 @@ func TestMain(m *testing.M) {
100
101
panic (fmt .Sprintf ("unable to create unstructuredCachineClient: %v" , err ))
101
102
}
102
103
104
+ if err := (& machinecontroller.Reconciler {
105
+ Client : mgr .GetClient (),
106
+ UnstructuredCachingClient : unstructuredCachingClient ,
107
+ APIReader : mgr .GetAPIReader (),
108
+ Tracker : tracker ,
109
+ }).SetupWithManager (ctx , mgr , controller.Options {MaxConcurrentReconciles : 1 }); err != nil {
110
+ panic (fmt .Sprintf ("Failed to start MachineReconciler: %v" , err ))
111
+ }
103
112
if err := (& machinesetcontroller.Reconciler {
104
113
Client : mgr .GetClient (),
105
114
UnstructuredCachingClient : unstructuredCachingClient ,
106
115
APIReader : mgr .GetAPIReader (),
107
116
Tracker : tracker ,
108
117
}).SetupWithManager (ctx , mgr , controller.Options {MaxConcurrentReconciles : 1 }); err != nil {
109
- panic (fmt .Sprintf ("Failed to start MMachineSetReconciler : %v" , err ))
118
+ panic (fmt .Sprintf ("Failed to start MachineSetReconciler : %v" , err ))
110
119
}
111
120
if err := (& Reconciler {
112
121
Client : mgr .GetClient (),
113
122
UnstructuredCachingClient : unstructuredCachingClient ,
114
123
APIReader : mgr .GetAPIReader (),
115
124
}).SetupWithManager (ctx , mgr , controller.Options {MaxConcurrentReconciles : 1 }); err != nil {
116
- panic (fmt .Sprintf ("Failed to start MMachineDeploymentReconciler : %v" , err ))
125
+ panic (fmt .Sprintf ("Failed to start MachineDeploymentReconciler : %v" , err ))
117
126
}
118
127
}
119
128
0 commit comments