4. Informer 机制详解：List-Watch 原理、Reflector、DeltaFIFO、Indexer、Store

Informer 是 client-go 中实现事件驱动、本地缓存与增量同步的核心机制。它通过 List-Watch 模式从 API Server 获取资源状态，并利用三层组件（Reflector、DeltaFIFO、Indexer）将数据高效地注入到本地 Store 中。理解 Informer 的每个环节，是优化控制面数据传输延迟与吞吐量的前提。

4.1 List-Watch 原理

List-Watch 是 Kubernetes 客户端与 API Server 之间的一种混合数据同步协议：

• List（全量拉取）：首次建立连接或 Watch 断开重连时，通过 HTTP GET 请求获取指定资源类型的完整对象列表。List 返回的 ResourceVersion 作为后续 Watch 的起点。
• Watch（增量推送）：基于 HTTP/1.1 长连接（或 WebSocket），持续监听资源变更事件（ADDED / MODIFIED / DELETED / BOOKMARK / ERROR）。API Server 将增量事件以 chunked 编码流式推送。

4.2 Reflector：List-Watch 的执行者

Reflector 是 Informer 中负责与 API Server 通信的组件。它封装了 List-Watch 循环，并将接收到的对象放入 DeltaFIFO。

核心职责

• List 与 Watch 循环：在 ListAndWatch() 方法中，先执行一次全量 List，然后进入 Watch 循环。
• 资源版本管理：记录最新的 resourceVersion，用于断线重连和 Watch 续传。
• 分页处理：当 List 返回的对象数量超过 paginationPageSize（默认 500）时，自动使用 continue 令牌分页拉取。
• 错误重试：Watch 连接超时或收到错误事件后，按指数退避策略重新 List。

4.3 DeltaFIFO：增量事件队列

DeltaFIFO 是一个按对象键（namespace/name）去重的先进先出队列，存储 Reflector 推送的增量事件（Delta）。每个 Delta 包含变更类型（Added / Updated / Deleted / Sync / Replaced）和对象的最新状态。

关键特性

// DeltaFIFO 核心数据结构
type DeltaFIFO struct {
    items   map[string]Deltas        // 按对象键存储 Delta 列表
    queue   []string                 // 有序的对象键列表
    knownObjects KeyListerGetter      // 通常指向 Indexer
    // ...
}

type Delta struct {
    Type   DeltaType   // Added, Updated, Deleted, Sync, Replaced
    Object interface{} // 对象的最新状态
}

type Deltas []Delta

4.4 Indexer 与 Store：本地缓存与索引

Indexer 是 client-go 提供的本地缓存层，它实现了 Store 接口，并额外支持基于索引的快速查询。当 DeltaFIFO 中的事件被 Pop 处理后，Informer 的事件处理器（ResourceEventHandler）会调用 Indexer 更新本地缓存。

Store 接口

Store 定义了对象增删改查的基本操作：

• Add(obj) / Update(obj) / Delete(obj)
• Get(obj) / GetByKey(key)
• List() / ListKeys()
• Replace(list, resourceVersion)：全量替换（用于 List 结果）
• Resync()：触发重同步

Indexer 扩展能力

Indexer 在 Store 基础上增加了索引函数（IndexFunc）和索引数据结构（Index），支持按任意字段快速查找对象：

// 创建按标签索引的 Indexer
indexers := cache.Indexers{
    "label:app": func(obj interface{}) ([]string, error) {
        pod := obj.(*v1.Pod)
        return []string{pod.Labels["app"]}, nil
    },
}
indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, indexers)

// 按索引查询
pods, _ := indexer.ByIndex("label:app", "nginx")

4.5 组件协作流程

1. 启动：Informer 启动后，Reflector 执行一次全量 List，将结果封装为 Replace Delta 推入 DeltaFIFO。
2. 全量同步：DeltaFIFO 的 Pop 方法取出 Replace Delta，调用 Indexer 的 Replace() 方法，用新数据覆盖本地缓存。
3. 增量监听：Reflector 进入 Watch 循环，收到 ADDED/MODIFIED/DELETED 事件后，构造对应 Delta 入队。
4. 增量处理：Pop 取出 Delta，调用 Indexer 的 Add/Update/Delete 更新缓存，同时触发 ResourceEventHandler 回调。
5. 定期重同步：每 resyncPeriod（默认 10 分钟），DeltaFIFO 注入 Sync 事件，强制 Indexer 重新列出所有对象并触发 Update 回调，确保事件不丢失。

4.6 常见问题与避坑