一、整体架构

很多运维人员和开发者常常因为不清楚 kube-controller-manager 的 Leader Election 实现细节而导致 HA 部署调试困难、故障排查耗时。下面从代码层面梳理整个选举流程，帮助快速定位问题。

层次	方法	职责
编排层	cmd/kube-controller-manager/app/controllermanager.go	决定是否启用 LE、编排多锁竞争、将 Controller 分配给选举引擎。
主要循环层	staging/src/k8s.io/client-go/tools/leaderelection/leaderelection.go	acquire → renew → release 三阶段循环，实现分布式锁。
锁实现层	staging/src/k8s.io/client-go/tools/leaderelection/resourcelock/lease.go	基于 Kubernetes Lease API 的分布式锁具体实现。

二、三个主要时间参数

Leader Election 的行为由以下三个时间参数控制：

LeaseDuration = 15s // 租约有效期。非 Leader 等待这么久未观察到续约后才能尝试抢占
RenewDeadline = 10s // 续约截止时间。Leader 必须在此时间内成功续约，否则放弃
RetryPeriod = 2s // 重试间隔。每次尝试 Acquire/Renew 的间隔

约束条件：

LeaseDuration> RenewDeadline> RetryPeriod ×

时序关系示意：

时间轴: 0s 2s 4s 6s 8s 10s 12s 15s
|-----|-----|-----|-----|-----|-----|-----|
从Leader来看，↑
RenewDeadline=10s
LeaseDuration=15s

三、Leader Election 主流程

┌───────────────────────────────────────────────┐
│ LeaderElector.Run │
├───────────────────────────────────────────────┤
│ . acquire ← 阻塞直到获取锁或 ctx 被取消 │
│ ├─ 循环: tryAcquireOrRenew 每 RetryPeriod 一次 │
│ └─ 成功 → 跳出循环 │
│ │
│ . go OnStartedLeading ← 异步启动业务逻辑 │
│ │
│ . renew ← 阻塞直到续约失败或 ctx 被取消 │
│ ├─ 循环: PollUntilContextTimeout( │
│ │ RetryPeriod,RenewDeadline。│
│ │ tryAcquireOrRenew) │
│ ├─ 在 RenewDeadline 内续约成功 → 继续循环 │
│ └─ 续约失败 → 跳出，放弃 Leader 身份 │
│ │
│ . OnStoppedLeading ← 总是调用│
│ └─ 如果 ReleaseOnCancel → tryRelease 主动释放锁 │
└───────────────────────────────────────────────┘

四、主要方法：tryAcquireOrRenew 的细节

This method is used both for acquiring a lock and renewing it.

Fast Path—— Leader 乐观续约：

if {
// 使用上一次观察到的 ResourceVersion 执行 Update Lease 调用
// 成功 → 更新本地 observedRecord，返回 true
// 失败→ 跳转到 Slow Path
尝试
}

The fast path handles majority of renewals with a single API call.

Slow Path—— 读‑改‑写：

# Get Lease 对象
IF NotFound THEN
Create Lease
ELSE
# 判断是否可抢占
IF HolderIdentity!= "" AND 租约未过期 AND 我不是 Holder THEN
RETURN false -- 别人持有有效租约。
不能抢占
END IF
# Update Lease 对象
IF 我是 Leader THEN
# 正常续约，LeaderTransitions 不变
UPDATE Lease…ELSE
# 抢占，LeaderTransitions +1
UPDATE Lease …END IF
END IF;

租约有效性判断（isLeaseValid)：

// observedTime + LeaseDuration> now 表示租约仍然有效
if observedTime.Add*time.Second).After) { …}

五、ResourceLock：基于 Lease API 的锁实现

The concrete lock implementation is LeaseLock,operating on Kubernetes resource type coordination.k8s.io/v1 – Lease.

演进路线： endpoints → configmaps → configmapsLeases/endpointsLeases → leases .

<\/tbody><\/table>

Lease.Spec 字段说明
.holderIdentity	A unique identifier of current holder .
.leasedurationseconds< codе><="" d="" t="">租约时长.leasedurationseconds<>
.acquireTime	获取锁的时间戳。
.renewTime	最近一次成功续约的时间戳。
.leaseTransitions	Leader 切换计数，用于监控频繁切换风险。
.preferredHolder	可选字段，用于优雅交接场景。
.strategy	当前仅支持 “OldestEmulationVersion”。

---