@@ -40,6 +40,7 @@ import (
40
40
"k8s.io/utils/ptr"
41
41
ctrl "sigs.k8s.io/controller-runtime"
42
42
"sigs.k8s.io/controller-runtime/pkg/cache"
43
+ "sigs.k8s.io/controller-runtime/pkg/healthz"
43
44
"sigs.k8s.io/controller-runtime/pkg/log/zap"
44
45
"sigs.k8s.io/controller-runtime/pkg/metrics/server"
45
46
@@ -146,6 +147,15 @@ func runManager(metricsAddr, probeAddr, watchNamespace string, enableLeaderElect
146
147
os .Exit (1 )
147
148
}
148
149
150
+ if err := mgr .AddHealthzCheck ("healthz" , healthz .Ping ); err != nil {
151
+ setupLog .Error (err , "unable to set up health check" )
152
+ os .Exit (1 )
153
+ }
154
+ if err := mgr .AddReadyzCheck ("readyz" , healthz .Ping ); err != nil {
155
+ setupLog .Error (err , "unable to set up ready check" )
156
+ os .Exit (1 )
157
+ }
158
+
149
159
versionString := "unknown"
150
160
if v , ok := debug .ReadBuildInfo (); ok {
151
161
versionString = fmt .Sprintf ("%s (%s)" , v .Main .Version , v .GoVersion )
@@ -226,6 +236,15 @@ func runMachineAPIControllersManager(metricsAddr, probeAddr, watchNamespace stri
226
236
os .Exit (1 )
227
237
}
228
238
239
+ if err := mgr .AddHealthzCheck ("healthz" , healthz .Ping ); err != nil {
240
+ setupLog .Error (err , "unable to set up health check" )
241
+ os .Exit (1 )
242
+ }
243
+ if err := mgr .AddReadyzCheck ("readyz" , healthz .Ping ); err != nil {
244
+ setupLog .Error (err , "unable to set up ready check" )
245
+ os .Exit (1 )
246
+ }
247
+
229
248
if err := (& controllers.MachineAPIControllersReconciler {
230
249
Client : mgr .GetClient (),
231
250
Scheme : mgr .GetScheme (),
0 commit comments