带你读《云原生应用开发 Operator原理与实践》第三章 Kubebuilder 原理3.3 Controller-runtime 模块分析(四)-阿里云开发者社区

开发者社区> 人民邮电出版社> 正文

带你读《云原生应用开发 Operator原理与实践》第三章 Kubebuilder 原理3.3 Controller-runtime 模块分析(四)

简介: 带你读《云原生应用开发 Operator原理与实践》第三章 Kubebuilder 原理3.3 Controller-runtime 模块分析
+关注继续查看

2. 创建

pkg/manager/internal.go中的 controllerManager对象实现了 Manager接口,可以通过manager.New()方法新建(见代码清单3-26

...

mgr,err:=manager.New(cfg,manager.Options{})iferr!=nil{

log.Error(err,"unabletosetupmanager")os.Exit(1)

}

...

 

其中,方法的第一个参数为 rest.Config对象,定义了如何访问Kube-APIServer ;第二个参数为 manager.Options对象,用于配置 Manager,主要包括以下内容。


 

(3)  Scheme结构。一般先通过k8s.io/apimachinery/pkg/runtime中的 NewScheme()方法获取Kubernetes的Scheme,然后再将CRD注册到Scheme中(见代码清单3-27)。

...

varscheme=runtime.NewScheme()

 

funcinit(){crd1.AddToScheme(scheme)crd2.AddToScheme(scheme)

...

}


...

 

(2)  MapperProvider是一个函数对象,其定义为 func(c*rest.Config)(meta.REST- Mapper,error),用于定义 Manager如何获取RESTMapper。默认通过 k8s.io/client-go中的 DiscoveryClient请求获取Kube-APIServer。

(3)  Logger用于定义 Manager的日志输出对象,默认使用 pkg/internal/log包下的全局参数 RuntimeLog。

(4)  SyncPeriod参数用于指定 Informer 重新同步并处理资源的时间间隔,默认为10小时。此参数也决定了Controller重新同步的时间间隔,每个 Controller的时间间隔以此参数为基准有10% 的抖动,以避免多个 Controller同时进行重新同步。

(5)   LeaderElection、LeaderElectionResourceLock、LeaderElectionNamespace、LeaderElectionID等用于开启和配置 Manager的选举。其中,LeaderElectionResource-Lock配置选举锁的类型可以为 Leases、Configmapsleases、Endpointsleases等, 默认为Configmapslease。LeaderElectionNamespace、LeaderElectionID用于配置锁资源的Namespace和Name(见代码清单3-28)。


LeaderElectionboolLeaderElectionResourceLockstringLeaderElectionNamespacestringLeaderElectionIDstring

//访问选举锁所在的APIServer的配置

LeaderElectionConfig*rest.Config



//当设置为True时,Manager结束前会主动释放选举锁,否则需要等到选举任期结束

//才能进⾏新的选举。此选项可以加快重新选举的速度

LeaderElectionReleaseOnCancelbool

 

//候选⼈强制获取 Leader的时间,相当于⼀个选举任期,默认为 15sLeaseDuration*time.Duration

//当选 Leader后,刷新选举信息的间隔,其需要⼩于 LeaseDuration,默认为 10sRenewDeadline*time.Duration

//候选⼈尝试竞选的时间间隔默认为 2sRetryPeriod*time.Duration

 

(6)  Namespace参数用于限制 Manager.Cache只监听指定 Namespace的资源,默认情况下无限制。

(7)  NewCache参数的类型为 cache.NewCacheFunc,Manager会调用此参数创建Cache,因此,可以用于自定义 Manager使用的 Cache。在默认情况下,Manager使用InformersMap对象实现 Cache接口,InformersMap接口的实现在 pkg/cache/internal/deleg_map.go中(见代码清单3-29)。

typeNewCacheFuncfunc(config*rest.Config,optsOptions)(Cache,error)

 

(8)  ClusterBuilder参数的类型为 ClientBuilder接口,Manager会调用此接口创建 Client,即 Manager.GetClient()返回的 Client。在默认情况下,Manager使用pkg/cluster下的 newClientBuilder对象创建 Client。

(9)  ClientDisableCacheFor参数用于配置 Client,指定某些资源对象的操作不使用缓存,而是直接操作 Kube-APIServer。

(10)   EventBroadcaster参数用于提供 Manager,以获取 EventRecorder,当前已不推荐使用,因为当Manager或Controller的生命周期短于EventBroadcaster的生命周期时,可能会导致 goroutine泄露。

2. 实现ControllerManager对象是 Manager的实现,其结构成员中部分成员是直接通过manager.Options传入的,或是通过 manager.Options传入的方法创建的,另外一些主要的成员如下。

(1)cluster.Cluster接口类型成员Cluster:提供 Manager接口中的匿名成员 cluster.

Cluster 的实现。

(2)[]Runnable类型成员 leaderElectionRunnables与 nonLeaderElectionRunnables:两者存储了所有注册到Manager中的 Controller、WebHookServer 以及自定义对象,按照是否需要遵循选举机制 []Runnable 类型成员分为两类,nonLeaderElectionRunnables中的 Runnable,在调用 Manager.Start()方法后会立即启动。

(3)   metricsListener和 healthProbeListener:类型都为 net.Listener,前者是Prometheus监控服务的监听对象,后者是健康检查服务的监听对象。

(4)   WebHookServer:WebHook的服务对象, 在Manager.GetWebhookServer()方法被调用时,进行创建并返回。

(5)   startCache:是函数对象,类型为 func(ctxcontext.Context)error,用于启动缓存的同步。 在启动 leaderElectionRunnables和 nonLeaderElectionRunnables之前,Manager会先调用此方法启动缓存同步,并等待同步完成,启动 Runnable。在实现上,startCache实际上是 cluster.Cluster.Start()方法。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Android开发中StackOverflowError
<div class="edit_area" id="330486" style="color:rgb(51,51,51); font-family:Arial; font-size:14px; line-height:26px"> <div style="margin:17pt 0cm 16.5pt"><strong><span style="font-size:32px">Andro
1085 0
Android开发中StackOverflowError
Android开发中StackOverflowError错误实例分析 一、概述  我在一个复杂的layout嵌套较多的android界面,碰到了java.lang.StackOverflowError这个Fatal Exception,app程序crash退出。这个错误出现的比较奇怪,在我做技术调研的时候,这个界面是放在单独的一个程序中展示的,工作很正常,没有出现这个严重错误,
958 0
来,你认为应用架构的核心使命是什么? | 开发者必读(053期)
最炫的技术新知、最热门的大咖公开课、最有趣的开发者活动、最实用的工具干货,就在《开发者必读》!
701 0
安卓开发之ScrollView
当界面不足以将所有的内容显示出来的时候便导致下面的部分内容无法显示出来 所有加上ScrollView 来讲要显示的内容放入之中便可以实现上下滚动界面内容 但是当要显示多个控件的时候会出错  原因是ScrollView只能有一个子控件  解决方法就是 用一个LinearLayout(或者别的布局)...
545 0
【iOS开发】UIScrollView 看不到内容、UIScrollView 不能滑动
初学者第一次使用 UIScrollView 的时候,很可能会遇到 UIScrollView 滑动不了,或者明明添加了内容,却看不到的问题。 这里展示最简洁、最常态化的一种在 UIScrollView 中添加可以滑动的 UIImageView 的案例。
653 0
安卓开发ScrollView嵌套ListView只显示一行
在用列表控件做一个“更多功能”的界面的时候 1 2 7 8 12 13 17 18 23 27 28 33 37 38 39 原本用ScrollView嵌套...
891 0
472
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载