k8s client-go源码分析 informer源码分析(3)-Reflector源码分析.doc
版权申诉
66 浏览量
2022-07-09
23:04:08
上传
评论
收藏 964KB DOC 举报
k8s client-go 源码分析 informer 源码分析(3)-Reflector 源码分析
k8s client-go k8s informers 实现了持续获取集群的所有资源对象、监听集群的资
源对象变化功能，并在本地维护了全量资源对象的内存缓存，以减少对 apiserver、对 etcd
的请求压力。Informers 在启动的时候会首先在客户端调用 List 接口来获取全量的对象集合，
然后通过 Watch 接口来获取增量的对象，然后更新本地缓存。
k8s client-go 源码分析 informer 源码分析(3)-Reflector 源码分析
1.Reflector 概述
Reflector 从 kube-apiserver 中 list&watch 资源对象，然后将对象的变化包装成 Delta 并将其
丢到 DeltaFIFO 中。简单点来说，就是将 Etcd 的对象及其变化反射到 DeltaFIFO 中。
Reflector 首先通过 List 操作获取全量的资源对象数据，调用 DeltaFIFO 的 Replace 方法全
量 插 入 DeltaFIFO ， 然 后 后 续 通 过 Watch 操 作 根 据 资 源 对 象 的 变 化 类 型 相 应 的 调 用
DeltaFIFO 的 Add、Update、Delete 方法，将对象及其变化插入到 DeltaFIFO 中。
Reflector 的健壮性处理机制
Reflector 有健壮性处理机制，用于处理与 apiserver 断连后重新进行 List&Watch 的场景。
也是因为有这样的健壮性处理机制，所以我们一般不去直接使用客户端的 Watch 方法来处
理自己的业务逻辑，而是使用 informers。
Reflector 核心操作
Reflector 的两个核心操作：
（1）List&Watch；
（2）将对象的变化包装成 Delta 然后扔进 DeltaFIFO。
informer 概要架构图
通过下面这个 informer 的概要架构图，可以大概看到 Reflector 在整个 informer 中所处的
位置及其作用。
评论0