INNER CODE UNIT · Go

func

kuberhealthy/kuberhealthy · cmd/kuberhealthy/leaderElection.go:22

func (r *leaderElectionRunner) onStartedLeading(ctx context.Context) {
	err := r.kh.StartLeaderTasks(ctx)
	if err != nil {
		log.Errorln("leader election: failed to start leader tasks:", err)
	}
}

// onStoppedLeading stops leader-only tasks when the lease is lost.
func (r *leaderElectionRunner) onStoppedLeading() {
	r.kh.StopLeaderTasks()
}

// onNewLeader logs leader transitions.
func (r *leaderElectionRunner) onNewLeader(identity string) {
	if identity == r.identity {
		return
	}
	log.Infoln("leader election: new leader elected:", identity)

View source record →