KubernetesInformer的示例分析是怎样的

Kubernetes Informer的示例分析是怎样的,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

创新互联建站服务项目包括都昌网站建设、都昌网站制作、都昌网页制作以及都昌网络营销策划等。多年来,我们专注于互联网行业,利用自身积累的技术优势、行业经验、深度合作伙伴关系等,向广大中小型企业、政府机构等提供互联网行业的解决方案,都昌网站推广取得了明显的社会效益与经济效益。目前,我们服务的客户以成都为中心已经辐射到都昌省份的部分城市,未来相信会继续扩大服务区域并继续获得客户的支持与信任!

熟悉Kubernetes的小伙伴们想必会有一窥源码的动机,领略大师的设计和实现,从官方开放出来的go-sdk来切入Kubernetes应该是个不错的选择。在client-go的工具包里面,informer是一个主要的工具,下文是小编对inform组件的主要功能和部分代码的简单介绍,若有错误之处,欢迎指出,小编果然献出铁头,供大家轻拍。

主要功能:

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

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

逻辑关系图(引用徐超大神的分享):

Kubernetes Informer的示例分析是怎样的

代码结构浅析:

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的示例分析是怎样的问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注创新互联行业资讯频道了解更多相关知识。


当前文章:KubernetesInformer的示例分析是怎样的
文章出自:http://scyanting.com/article/giddgg.html