Skip to content

Commit a0b9637

Browse files
authored
fix: leader election use nodepool value for lock name (#413)
1 parent de819ef commit a0b9637

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

cmd/scheduler/app/server.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,11 @@ func Run(opt *options.ServerOption, config *restclient.Config, mux *http.ServeMu
174174
// Prepare event clients.
175175
broadcaster := record.NewBroadcaster()
176176
broadcaster.StartRecordingToSink(&corev1.EventSinkImpl{Interface: leaderElectionClient.CoreV1().Events(opt.Namspace)})
177-
eventRecorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: opt.SchedulerName})
177+
componentName := opt.SchedulerName
178+
if len(opt.NodePoolLabelValue) > 0 {
179+
componentName = fmt.Sprintf("%s-%s", opt.SchedulerName, opt.NodePoolLabelValue)
180+
}
181+
eventRecorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: componentName})
178182

179183
hostname, err := os.Hostname()
180184
if err != nil {
@@ -185,7 +189,7 @@ func Run(opt *options.ServerOption, config *restclient.Config, mux *http.ServeMu
185189

186190
rl, err := resourcelock.New(resourcelock.LeasesResourceLock,
187191
opt.Namspace,
188-
opt.SchedulerName,
192+
componentName,
189193
leaderElectionClient.CoreV1(),
190194
leaderElectionClient.CoordinationV1(),
191195
resourcelock.ResourceLockConfig{

0 commit comments

Comments
 (0)