@@ -151,6 +151,7 @@ func main() {
151
151
}
152
152
153
153
activity := activity .NewWorkspaceActivity ()
154
+
154
155
timeoutReconciler , err := controllers .NewTimeoutReconciler (mgr .GetClient (), mgr .GetEventRecorderFor ("workspace" ), cfg .Manager , activity , maintenanceReconciler )
155
156
if err != nil {
156
157
setupLog .Error (err , "unable to create timeout controller" , "controller" , "Timeout" )
@@ -164,14 +165,17 @@ func main() {
164
165
}
165
166
166
167
workspaceReconciler .OnReconcile = wsmanService .OnWorkspaceReconcile
168
+
167
169
if err = workspaceReconciler .SetupWithManager (mgr ); err != nil {
168
170
setupLog .Error (err , "unable to setup workspace controller with manager" , "controller" , "Workspace" )
169
171
os .Exit (1 )
170
172
}
173
+
171
174
if err = timeoutReconciler .SetupWithManager (mgr ); err != nil {
172
175
setupLog .Error (err , "unable to setup timeout controller with manager" , "controller" , "Timeout" )
173
176
os .Exit (1 )
174
177
}
178
+
175
179
if err = maintenanceReconciler .SetupWithManager (mgr ); err != nil {
176
180
setupLog .Error (err , "unable to setup maintenance controller with manager" , "controller" , "Maintenance" )
177
181
os .Exit (1 )
@@ -197,8 +201,10 @@ func main() {
197
201
setupLog .Info ("starting manager" )
198
202
if err := mgr .Start (ctrl .SetupSignalHandler ()); err != nil {
199
203
setupLog .Error (err , "problem running manager" )
200
- os .Exit (1 )
201
204
}
205
+
206
+ setupLog .Info ("new leader elected" )
207
+ os .Exit (1 )
202
208
}
203
209
204
210
func setupGRPCService (cfg * config.ServiceConfiguration , k8s client.Client , activity * activity.WorkspaceActivity , maintenance maintenance.Maintenance ) (* service.WorkspaceManagerServer , error ) {
0 commit comments