Kubernetes Informer的示例分析是怎样的
Kubernetes Informer的示例分析是怎样的，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
熟悉Kubernetes的小伙伴们想必会有一窥源码的动机，领略大师的设计和实现，从官方开放出来的go-sdk来切入Kubernetes应该是个不错的选择。在client-go的工具包里面，informer是一个主要的工具，下文是小编对inform组件的主要功能和部分代码的简单介绍，若有错误之处，欢迎指出，小编果然献出铁头，供大家轻拍。
主要功能：
List和Watch方法，从APIServer同步/解码对象到本地缓存，另外提供本地缓存的访问入口，减少对APIServer的访问压力。
AddEventHandler方法，handler注册的入口，用户变更对象之后触发handler对应的函数，将对象状态信息写到workqueue，供worker消费。
逻辑关系图(引用徐超大神的分享)：
代码结构浅析：
sharedInformerFactory
infomers成员：维护Type接口到SharedIndexInformer的map，此处映射到sharedIndexInformer struct指针变量，工厂设计模式。
startedInformers成员：维护Type接口到BOOL值的映射，启动informer之前在此判断，避免重复启动infromer。
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方法。
...
熟悉Informer实现的主要策略和机制之后，会对后续开发controller带来很多的信心和好处，方便大家持续工作在Kubernetes平台上。简单描述informer的主要结构，还有一些需要研究的地方，比如说缓存压缩，protobuf decode/encode机制，processListener的消息缓存机制，锁通知机制等等，谢谢。
关于Kubernetes Informer的示例分析是怎样的问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注行业资讯频道了解更多相关知识。
