func()

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
}