前言
本文聚焦client-go v11.0.0 controller框架Informer對(duì)象喳钟，分析源碼理解informer的實(shí)現(xiàn)蒿赢。更全面的介紹參考官方文檔: https://github.com/kubernetes/client-go
1 informer對(duì)象關(guān)系
informer對(duì)象即controller struct（下文的controller即informer）陨簇。controller對(duì)象關(guān)聯(lián)關(guān)系比較復(fù)雜，上面的組件關(guān)系主要抓住幾個(gè)關(guān)鍵對(duì)象：controller腺律，Reflector逮诲，cache。這幾個(gè)對(duì)象就是client-go Controller Framework的三個(gè)核心對(duì)象吟温。從controller組件關(guān)系看序仙，controller對(duì)象包含了reflector, 并通過(guò)DeltaFIFO關(guān)聯(lián)了indexer（cache對(duì)象）。
2 一個(gè)controller創(chuàng)建和運(yùn)行流程
我們首先分析controller的總體流程鲁豪，其次分析controller框架內(nèi)部如何處理DeltaFIFO彈出的Object潘悼。
2.1 controller總體流程分析
下圖來(lái)自client-go Controller Framework官方文檔，有幾個(gè)重要的概念： reflector爬橡，informer治唤，indexer。
reflector：
Reflector利用List&&Watch機(jī)制糙申，獲取k8s runtime.object對(duì)象變化狀態(tài)并同步到DeltaFIFO宾添。Reflector機(jī)制在《Client-Go源碼分析：Reflector》中詳細(xì)介紹。
informer：
Informer不斷從DeltaFIFO中彈出對(duì)象柜裸，并和內(nèi)存存儲(chǔ)對(duì)象Indexer同步缕陕，隨后調(diào)用用戶注冊(cè)的回調(diào)函數(shù)ResourceEventHandlers。
indexer：
Indexer是內(nèi)存存儲(chǔ)對(duì)象粘室，具有存儲(chǔ)和快速索引的功能榄檬。Indexer機(jī)制在《Client-Go源碼分析：Indexer, cache, threadSafeMap》中詳細(xì)介紹卜范。
下圖對(duì)官方架構(gòu)圖的簡(jiǎn)化衔统，聚焦在Informer對(duì)象。
2.2 controller內(nèi)部對(duì)象處理分析
我們以函數(shù)調(diào)用關(guān)系圖關(guān)聯(lián)上面的簡(jiǎn)化圖愿伴。
Controller驹溃，Reflector狭莱，Indexer對(duì)象創(chuàng)建過(guò)程不再贅述。這里僅介紹fifo pop后續(xù)的流程险掀，ListAndWatch push到fifo的過(guò)程在《client-go源碼分析：Reflector》介紹。processLoop調(diào)用c.config.Queue.Pop()持續(xù)從fifo （DeltaFIFO）中彈出對(duì)象湾宙，并調(diào)用Process回調(diào)函數(shù)處理彈出的對(duì)象樟氢。
根據(jù)delta_fifo.go的Pop函數(shù)實(shí)現(xiàn)冈绊，DeltaFIFO Pop對(duì)象是Deltas類型，該類型定義如下：
Process的入?yún)⑹荄eltas類型的對(duì)象埠啃，即某個(gè)runtime.object的一組Delta狀態(tài)死宣，因此Process能實(shí)現(xiàn)有順序的更新Indexer，資源的狀態(tài)是同步+增量的方式同步的碴开。下列代碼中毅该，clientState是indexer對(duì)象，clientState.Get(), clientState.Update(), clientState.Delete()就是對(duì)Indexer對(duì)象的操作潦牛。
3 結(jié)語(yǔ)
4 參考文檔
https://github.com/kubernetes/client-go
https://blog.csdn.net/weixin_42663840/article/details/81699303
