vendor/k8s.io/client-go/tools/leaderelection/leaderelection.go

    func (le *LeaderElector) acquire(ctx context.Context) bool { ctx, cancel := context.WithCancel(ctx) defer cancel()

    succeeded := false desc := le.config.Lock.Describe()

    klog.Infof(“attempting to acquire leader lease %v…”, desc)

    wait.JitterUntil(func() {

    1.   succeeded = le.tryAcquireOrRenew()
    3.   le.maybeReportTransition()
    5.   if !succeeded {
    7.      klog.V(4).Infof("failed to acquire lease %v", desc)
    9.      return      }
    11.   le.config.Lock.RecordEvent("became leader")
    13.   le.metrics.leaderOn(le.config.Name)
    15.   klog.Infof("successfully acquired lease %v", desc)
    17.   cancel()

    }, le.config.RetryPeriod, JitterFactor, true, ctx.Done())

    return succeeded}

    tryAcquireOrRenew