in pkg/k8s/election/election.go [90:106]
func (le *leaderElection) onNewLeader(identity string) {
if identity == resourcelock.UnknownLeader {
return
}
select {
case <-le.initChan:
break
default:
// A leader has been elected.
close(le.initChan)
}
le.mx.Lock()
defer le.mx.Unlock()
le.id = identity
}