跳到主要内容

首页博客 AI提示词 GitHub精选代理工具

Kubernetes Informer 核心机制与源码结构解析 | 极客日志

目录

Kubernetes Informer 核心机制与源码结构解析
主要功能
代码结构浅析
sharedInformerFactory
deploymentInformer
sharedIndexInformer
indexer
controller
processor
reflector
config
DeltaFIFO
processorListener

💰 8折买阿里云服务器限时8折了解详情

Go / Golang

Kubernetes Informer 核心机制与源码结构解析

Kubernetes Informer 是 client-go 中的核心工具，负责从 APIServer 同步对象至本地缓存并提供事件通知。其通过 List 和 Watch 机制减少 API 请求压力，利用 AddEventHandler 注册回调处理对象变更。核心组件包括 sharedInformerFactory 管理 Informer 生命周期，sharedIndexInformer 维护缓存与控制器逻辑，controller 协调 Reflector 与 Processor 进行数据同步及事件分发。理解 Informer 的工厂模式、缓存压缩及消息队列机制有助于开发高效的 Kubernetes Controller。

PhpPioneer发布于 2019/3/10 浏览

Kubernetes Informer 核心机制与源码结构解析

Kubernetes Informer 核心机制与源码结构解析

主要功能

List 和 Watch 方法，从 APIServer 同步/解码对象到本地缓存，另外提供本地缓存的访问入口，减少对 APIServer 的访问压力。

AddEventHandler 方法，handler 注册的入口，用户变更对象之后触发 handler 对应的函数，将对象状态信息写到 workqueue，供 worker 消费。

代码结构浅析

sharedInformerFactory

infomers 成员：维护 Type 接口到 SharedIndexInformer 的 map，此处映射到 sharedIndexInformer struct 指针变量，工厂设计模式。
startedInformers 成员：维护 Type 接口到 BOOL 值的映射，启动 informer 之前在此判断，避免重复启动 informer。
Start 方法：迭代 informers 成员，调用 informer.run 方法启动 informer。
InformerFor 方法：为 informers 成员持续增加 entry。
...

deploymentInformer

factory 成员：实现 SharedInformerFactory 接口的结构变量，此处赋值为 sharedInformerFactory struct 指针变量。
Informer 方法：调用 factory 的 InformerFor 方法，返回 sharedIndexInformer 指针对象。
Lister 方法：返回 informer 的 indexer 成员，用以读取本地缓存。
...

sharedIndexInformer

indexer 成员：实现 Indexer 接口，维护本地缓存 (map[string]interface{})，此处赋值为 cache struct 指针变量。
controller 成员：实现 Controller 接口，维护 APIServer 到本地缓存的同步机制，同时保持与 processor 的通讯，此处赋值为 controller struct 指针对象。
processor 成员：保持与 controller 的通讯，触发 handler 对应的方法，此处赋值为 sharedProcessor struct 指针对象。
AddEventHandler 方法：创建 processorListener struct 值对象，append 到 processor 成员的 listeners 和 syncinglisteners。
HandleDelta 方法：迭代 controller.config.Queue.items[key](Delta 切片)，调用 indexer.Add/Delete/Update 更新本地缓存，同时调用 processor.distribute 方法，按需迭代 processor 的 listeners 和 syncinglisteners，下发消息到 listener 的消息队列。
...

indexer

cacheStorage 成员：实现 ThreadSafeStore 接口，维护本地线程安全的缓存 map[string]interface{}，此处赋值为 threadSafeMap struct 指针变量。
keyFunc 成员：维护本地缓存 key 的函数。
Add/Delete/Update/List 方法：支撑对本地缓存的常用操作。
...

controller

reflector 成员：利用 resourceVersion 机制衔接调用 listerWatcher.List/Watch 方法，从 APIServer 同步/解码对象到 config.Queue.items(map[string]Deltas) 中，此处赋值为 Reflect struct 指针对象。
config 成员：维护链队列和对象操作映射 (map[string]Deltas)，此处赋值为 Config struct 值对象。
processloop 方法：传入 config.Process 成员，循环调用 config.Queue.Pop 方法。
...

processor

listeners 成员：processorListener struct 指针变量的切片。
run 方法：迭代 listeners，调用 processorListener.run/pop 方法，触发 processorListener.handler.OnAdd/OnUpdate/OnDelete 方法。
...

reflector

store 成员：实现 Store 接口，此处赋值为 DeltaFIFO struct 指针对象。
listerWatcher 成员：实现 ListerWatcher 的 List/Watch 方法，从 APIServer 同步/解码对象，此处赋值为 ListWatch struct 指针变量。
ListAndWatch 方法：调用 listerWatcher 成员的 List/Watch 方法，完成对象从 APIServer 的同步/解码，然后调用 syncWith 和 watchHandler 方法，把事件和对象同步到 store 的存储成员中。
syncWith 方法：调用 Store 接口的 Replace 方法，同步事件和对象信息。
watchHandler 方法：调用 Store 接口的 Add/Update/Delete 方法，同步事件和对象信息。
...

config

Queue 成员：实现 Queue 接口，此处赋值为 DeltaFIFO struct 指针对象。
Process 成员：值为 sharedIndexInformer.HandleDelta 方法。
...

DeltaFIFO

items 成员：map[string]Deltas，存储对象和操作信息。
queue 成员：[]string，简单的链队列。
knownObjects 成员：实现 KeyListerGetter 接口，此处赋值为 cache struct 指针对象。
Pop 方法：从 queue 成员 pop，调用 config.Process 方法。
Add/Delete/Update/Replace 方法：调用 queueActionLocked 方法。
queueActionLocked 方法：维护 items 和 queue 成员。
...

processorListener

nextCh 成员：从本地 pendingNotifications 或者 addCh 生产消息，run 方法消费消息。
addCh 成员：从调用 add 方法生产消息，写入本地 pendingNotifications 或者传递给 nextCh。
pendingNotifications 成员：维护本地缓冲消息，此处赋值为 RingGrowing struct 值对象。
pop 方法：维护 nextCh 和 addCh 的消息传递。
run 方法：消费 nextCh 消息，按需调用 processorListener.OnAdd/OnUpdate/OnDelete 方法。
...

💰 8折买阿里云服务器限时8折购买
🦞 5分钟部署阿里云小龙虾了解详情
🤖 一键搭建Deepseek满血版了解详情
一键打造专属AI 智能体了解详情

极客日志微信公众号二维码

微信扫一扫，关注极客日志

微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog

更多推荐文章

Ubuntu 安装 MySQL 社区版
Spring 框架 JSR-250 注解详解
DWR3 基于 Spring MVC 配置 Controller 的方法

相关免费在线工具

Base64 字符串编码/解码
将字符串编码和解码为其 Base64 格式表示形式即可。在线工具，Base64 字符串编码/解码在线工具，online
Base64 文件转换器
将字符串、文件或图像转换为其 Base64 表示形式。在线工具，Base64 文件转换器在线工具，online
Markdown转HTML
将 Markdown（GFM）转为 HTML 片段，浏览器内 marked 解析；与 HTML转Markdown 互为补充。在线工具，Markdown转HTML在线工具，online
HTML转Markdown
将 HTML 片段转为 GitHub Flavored Markdown，支持标题、列表、链接、代码块与表格等；浏览器内处理，可链接预填。在线工具，HTML转Markdown在线工具，online
JSON 压缩
通过删除不必要的空白来缩小和压缩JSON。在线工具，JSON 压缩在线工具，online
JSON美化和格式化
将JSON字符串修饰为友好的可读格式。在线工具，JSON美化和格式化在线工具，online