k8s之kubebuilder简单理解
kubebuilder流程
1、創建manager,ctrl.NewManager,包括設置 shemme和端口、選主信息等配置、NewCluster(用來訪問k8s,主要包括newCache和New讀寫client)、newEventRecorder。
1.1、newCache包括創建informerMap,分為structured、unstructured與metadata,其實最終都是調用newSpecificInformersMap,在newSpecificInformersMap中通過createListWatcher來NewListWatch對象,通過informersByGVK來記錄schema中每個GVK對象與informer的對應關系,使用時可根據GVK得到informer再去得到litser和watcher對象。
1.2、newClient包括newApiReader和newWriteObj,apiReader直接從apiserver讀寫對象,writeObj實現了讀寫分離的Client,寫直接寫apiserver,讀先讀cache讀不到則通過clientset。
2、創建builder(controller),controller.SetupWithManager主要包括 設置配置、doController來創建controller、doWatch來設置需要監聽的資源,對于監聽資源會在informer上添加回調函數進行filter。
2.1、doController調用controller.New來創建controller并添加到manager;
2.2、doWatch主要watch當前資源,包括forInput,ownsInput(owner為當前資源),以及watchsInput,最后調用ctrl.Watch來注冊,且watch的是localStore,并且watch是加鎖的,防止并發問題。
3、啟動manager,啟動監控服務、啟動健康檢查服務、啟動非選主服務、啟動選主服務
3.1、對于非選主服務webhook主要包括 等待cache同步,啟動n個worker,每個Worker不斷從workerQueue的req數據,之后調用c.Do.Reconcile來調諧處理取到的req對象。
3.2、對于選主服務controller,最前邊加了一步 加入到選主服務隊列,其他的和webhook完全相同。(若開啟多節點競爭選主服務則只有主節點會啟動控制器執行reconcile,而從節點只是用于實現高可用,并會不斷競爭選主,關閉選主服務則誰先啟動誰一直占據主節點)
controller配置選項:
Owns:監聽dengployment且該deployment的Owner是當前資源,deployment發生變化則將當前資源owner重新入隊workqueue。使用全局的eventfilter+own的predicates;
For:監聽owner當前資源,使用全局eventfilter;
Watches:監聽dengployment,使用全局的eventfilter+watches自己實現的入隊器EventHandler,設置該資源的獨有的事件監聽規則,并能夠自定義入隊的資源類型;
EventFilter:變更過濾器,是添加在informer的回調函數,可以針對watch的所有資源統一地設置事件監聽規則;
Options:worker數量、ratelamiter等參數設置;
最佳實踐:
1、不應該在一個reconciler邏輯中進行兩次資源的update(update status除外),否則會引發版本不一致的報錯。
總結
以上是生活随笔為你收集整理的k8s之kubebuilder简单理解的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Golang之pprof使用
- 下一篇: 41款常用APP被爆过度索取权限、数据共