kubelet的主要工作是創(chuàng)建、銷毀Pod痒蓬。kubelet需要對Pod資源進行watch，kubelet會 watch想要watch的Pod是那些已經(jīng)分配到本節(jié)點的Pods。本篇文章將從代碼實現(xiàn)探究一下kubelet對pod資源的watch實現(xiàn)舌剂。
本次分析是基于kubernetes tag v1.9.0
kubelet對pod資源的watch
入口程序
pkg/kubelet/kubelet.go NewMainKubelet()
1. NewMainKubelet()將會調(diào)用makePodSourceConfig()方法；
2. 在makePodSourceConfig()方法中暑椰，pod資源以三種方式獲得：第一種是通過文件獲得霍转，文件一般放在/etc/kubernetes/manifests目錄下面，啟動kubelet時可以通過指定–config覆蓋一汽，第二種也是通過文件過得避消，只不過文件是通過URL獲取的,URL可以在啟動kubelet時通過ManifestURL指定，第三種是通過watch kube-apiserver獲取召夹。其中前兩種模式下岩喷，我們稱kubelet運行在standalone模式下；我們將看看第三種方式的代碼實現(xiàn)监憎；
NewSourceApiserver
pkg／kubelet/config/apiserver.go NewSourceApiserver()
1. 將會調(diào)用NewListWatchFromClient()方法纱意；
2. 將會調(diào)用NewSourceApiserverFromLW()方法；
NewListWatchFromClient
client-go/tools/cache/listwatch.go NewListWatchFromClient()
1. NewListWatchFromClient()方法將返回一個ListWatch結(jié)構(gòu)體鲸阔，包含listFunc和watchFunc偷霉；
2. listFunc用于List，watchFunc用于Watch隶债；
3. ListWatch會傳入NewSourceApiserverFromLW()方法腾它；
NewSourceApiserverFromLW
pkg/kubelet/config/apiserver.go NewSourceApiserverFromLW()
1. 首先創(chuàng)建了一個send函數(shù)，它將從apiserver獲取的pods傳送到updates channel中死讹；
2. 這些Pods是從哪里獲取的了瞒滴？是通過構(gòu)建一個reflector，然后run獲得Pods信息；
Reflector-獲取Pods信息
client-go/tools/cache/reflector.go NewReflector()
1. Reflector對象妓忍，主要數(shù)據(jù)成員：ListerWatcher虏两，ListerWatcher是接口對象，包括方法List()和Watch()世剖；這里定罢，ListWatch對象將作為Reflector對象的ListerWatcher數(shù)據(jù)成員；
Reflector-執(zhí)行ListAndWatch
client-go/tools/cache/reflector.go Run()
1. 啟動協(xié)程執(zhí)行執(zhí)行reflector的ListAndWatch()方法旁瘫；
2. ListAndWatch()方法
(1) ListAndWatch()方法在之前的文章中的kube-apiserver對etcd的watch機制已經(jīng)介紹過祖凫。
(2) 調(diào)用ListFunc和WatchFunc去List和Watch apiserver的資源；
(3) 并調(diào)用reflector的watchHandler()方法酬凳；
listFunc/watchFunc
1. listFunc首先Get()惠况，說明發(fā)起一個Get請求，再看看Namespace(namespace)宁仔，其實只是在request設(shè)置namespace字段稠屠，再看看Resource函數(shù),設(shè)置request的resource字段,VersionedParams主要對options進行序列化，options主要包括ResourceVersion和TimeoutSeconds這兩個參數(shù)翎苫，F(xiàn)ieldsSelectorParam函數(shù)主要將filter函數(shù)進行序列化权埠，深入分析這個函數(shù)，你可以發(fā)現(xiàn)其實他將他序列化到一個嵌套的map里面煎谍。Do()函數(shù)發(fā)起真正的請求攘蔽，并收到response，然后用r.transformResponse去處理response粱快，包裝成Result返回秩彤。Get()函數(shù)則主要對Result進行反序列化。最后返回結(jié)果事哭。
2. watchFunc很大一部分與ListFunc重合了,比如Get()、Namespace(namespace)瓜富、Resource(resource)鳍咱、VersionedParams(&options, api.ParameterCodec)，有兩個比較特殊的函數(shù)Prefix(“watch”)和Watch()与柑。Prefix(“watch”)主要在pathPrefix的結(jié)尾增加了watch字段谤辜，用來和List請求區(qū)分。
3. Watch()方法將返回watch.Interface价捧，這個watch.Interface專門用來傳送kubelet想要watch的資源丑念。Watch首先會發(fā)起一個request，然后反序列化response结蟋，從response中獲得watch.Interface脯倚。
reflector.watchHandler
client-go/tools/cache/reflector.go watchHandler()
1. 從channel讀取event，然后更新到r.store；
2. r.store是什么呢推正？創(chuàng)建reflector時恍涂，定義了cache的類型為UndeltaStore；
UndeltaStore
client-go/tools/cache/undelta_store.go Add()/Update()/Delete()/Replace()
1. 執(zhí)行u.PushFunc(u.Store.List())操作植榕，PushFunc函數(shù)就cache.NewUndeltaStore(send, cache.MetaNamespaceKeyFunc)里面的send函數(shù)再沧，它將從apiserver獲取的pods傳送到updates channel中，kubelet從updates這個channel獲取到Pod信息進行處理尊残。
2. 這里無論是add炒瘸、delete或者modify， u.PushFunc(u.Store.List())他會發(fā)送存儲的所有pods寝衫。因為在這些操作之前什燕，它都會先操作Store里面的pods對象，確保Store里面存儲的是分配到該節(jié)點的Pod的最新信息竞端。至于kubelet怎么處理獲取的pods信息屎即，這就不屬于watch機制該討論的范疇了。
相關(guān)閱讀：
1.?http://licyhust.com/
