Skip to content

Commit 5c7fa0b

Browse files
committed
Start the grpc server after leader election
1 parent 7f968fa commit 5c7fa0b

File tree

1 file changed

+12
-6
lines changed

1 file changed

+12
-6
lines changed

components/ws-manager-mk2/main.go

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -170,13 +170,19 @@ func main() {
170170
os.Exit(1)
171171
}
172172

173-
wsmanService, err := setupGRPCService(cfg, mgr.GetClient(), maintenanceReconciler)
174-
if err != nil {
175-
setupLog.Error(err, "unable to start manager service")
176-
os.Exit(1)
177-
}
173+
// Wait for leader election to start the GRPC server
174+
go func() {
175+
<-mgr.Elected()
176+
177+
wsmanService, err := setupGRPCService(cfg, mgr.GetClient(), maintenanceReconciler)
178+
if err != nil {
179+
setupLog.Error(err, "unable to start manager service")
180+
os.Exit(1)
181+
}
182+
183+
workspaceReconciler.OnReconcile = wsmanService.OnWorkspaceReconcile
184+
}()
178185

179-
workspaceReconciler.OnReconcile = wsmanService.OnWorkspaceReconcile
180186
if err = workspaceReconciler.SetupWithManager(mgr); err != nil {
181187
setupLog.Error(err, "unable to setup workspace controller with manager", "controller", "Workspace")
182188
os.Exit(1)

0 commit comments

Comments
 (0)