k8s client-go源码分析 informer源码分析(2)-初始化与启动分析.doc

nformerFactory 的结构体定义，它是 informer 的工厂类，负责创建并管理 informer 实例： ```go type sharedInformerFactory struct { client client.Interface // ... defaultResync time.Duration // ... lock sync.Mutex informers map[reflect.Type]informers.SharedInformer // ... } ``` `sharedInformerFactory` 包含了 Kubernetes API 客户端、默认的资源重新同步间隔、锁以及一个映射，用于存储不同类型的 informer 实例。在 `NewSharedInformerFactory` 中，传入的 `client` 参数是 Kubernetes API 的客户端，`defaultResync` 参数定义了默认的资源重新同步时间间隔。 2. 创建 Informer 调用 `podInformer.Informer()` 会创建特定资源（如 Pod）的 informer。这个过程会返回一个实现了 `Informer` 接口的实例。`Informer` 接口通常由 `NewSharedInformer` 函数实现，它会创建 `Reflector` 和 `Indexer`，并配置它们之间的交互。 3. 启动 Informer Factory `factory.Start(stopper)` 会启动所有的 informer。`stopper` 是一个停止通道，当接收到信号时，会停止 informer 的运行。`Start` 方法会遍历所有的 informer，并启动它们。启动过程包括启动 `Reflector` 进行 `list` 和 `watch` 操作。 4. 确保 Cache 同步 `cache.WaitForCacheSync(stopper, informer.HasSynced)` 会等待所有 informer 的本地缓存完成初始同步。`HasSynced` 方法会检查 informer 是否已经完成了首次全量同步。如果超时未完成，将会抛出错误。 5. Reflector 工作原理 `Reflector` 使用 `ListAndWatch` 方法从 API 服务器获取资源对象。`List` 获取当前所有资源的快照，`Watch` 监听资源的变化。这些变更会被封装成 `Delta` 并放入 `DeltaFIFO`。 6. DeltaFIFO 与 Controller `DeltaFIFO` 是一个队列，内部包含一个 map 和一个队列，用于存储资源对象及其变化。`Controller` 从 `DeltaFIFO` 中取出对象，根据 `Delta` 更新 `Indexer` 中的本地缓存，并通知处理器（`Processor`）。 7. Indexer `Indexer` 是一个高效的本地缓存，可以通过索引快速查找资源对象，减少对 API 服务器的请求。 8. ResourceEventHandler 用户可以注册自定义的 `ResourceEventHandler`，当资源对象发生变化时，对应的处理器会被调用，执行用户定义的逻辑。 总结，Kubernetes client-go 中的 informer 机制通过 `Reflector`、`DeltaFIFO`、`Controller` 和 `Indexer` 等组件，实现了高效、低延迟地获取和监听集群资源变化的功能。初始化和启动过程中，首先创建 informer 工厂，然后创建特定资源的 informer，接着启动工厂，确保缓存同步后，就可以开始处理资源的变更事件。这种设计大大减轻了对 API 服务器的压力，提高了系统的整体效率。