带你读《云原生应用开发 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()方法获取KubernetesScheme,然后再将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用于配置锁资源的NamespaceName(见代码清单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,当前已不推荐使用,因为当ManagerController的生命周期短于EventBroadcaster的生命周期时,可能会导致 goroutine泄露。

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

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

Cluster 的实现。

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

(3)   metricsListenerhealthProbeListener:类型都为 net.Listener,前者是Prome- theus监控服务的监听对象,后者是健康检查服务的监听对象。

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

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

相关文章
|
6月前
|
运维 监控 Cloud Native
【云故事探索】NO.17:国诚投顾的云原生 Serverless 实践
国诚投顾携手阿里云,依托Serverless架构实现技术全面升级,构建高弹性、智能化技术底座,提升业务稳定性与运行效率。通过云原生API网关、微服务治理与智能监控,实现流量精细化管理与系统可观测性增强,打造安全、敏捷的智能投顾平台,助力行业数字化变革。
【云故事探索】NO.17:国诚投顾的云原生 Serverless 实践
|
8月前
|
Kubernetes Cloud Native 安全
云原生机密计算新范式 PeerPods技术方案在阿里云上的落地和实践
PeerPods 技术价值已在阿里云实际场景中深度落地。
|
6月前
|
运维 监控 Cloud Native
【云故事探索】NO.17:国诚投顾的云原生 Serverless 实践
通过与阿里云深度合作,国诚投顾完成了从传统 ECS 架构向云原生 Serverless 架构的全面转型。新的技术架构不仅解决了原有系统在稳定性、弹性、运维效率等方面的痛点,还在成本控制、API 治理、可观测性、DevOps 自动化等方面实现了全方位升级。
|
8月前
|
Kubernetes Cloud Native 安全
云原生机密计算新范式 PeerPods 技术方案在阿里云上的落地和实践
PeerPods 技术价值已在阿里云实际场景中深度落地。
|
4月前
|
人工智能 Cloud Native 算法
拔俗云原生 AI 临床大数据平台:赋能医学科研的开发者实践
AI临床大数据科研平台依托阿里云、腾讯云,打通医疗数据孤岛,提供从数据治理到模型落地的全链路支持。通过联邦学习、弹性算力与安全合规技术,实现跨机构协作与高效训练,助力开发者提升科研效率,推动医学AI创新落地。(238字)
310 7
|
10月前
|
运维 Cloud Native 测试技术
极氪汽车云原生架构落地实践
随着极氪数字业务的飞速发展,背后的 IT 技术也在不断更新迭代。极氪极为重视客户对服务的体验,并将系统稳定性、业务功能的迭代效率、问题的快速定位和解决视为构建核心竞争力的基石。
|
6月前
|
弹性计算 运维 Cloud Native
【云故事探索】NO.17:国诚投顾的云原生Serverless实践
简介: 通过与阿里云深度合作,国诚投顾完成了从传统 ECS 架构向云原生 Serverless 架构的全面转型。新的技术架构不仅解决了原有系统在稳定性、弹性、运维效率等方面的痛点,还在成本控制、API 治理、可观测性、DevOps 自动化等方面实现了全方位升级。
178 1
|
5月前
|
存储 弹性计算 Cloud Native
云原生数据库的演进与应用实践
随着企业业务扩展,传统数据库难以应对高并发与弹性需求。云原生数据库应运而生,具备计算存储分离、弹性伸缩、高可用等核心特性,广泛应用于电商、金融、物联网等场景。阿里云PolarDB、Lindorm等产品已形成完善生态,助力企业高效处理数据。未来,AI驱动、Serverless与多云兼容将推动其进一步发展。
271 8
|
7月前
|
Cloud Native 中间件 调度
云原生信息提取系统:容器化流程与CI/CD集成实践
本文介绍如何通过工程化手段解决数据提取任务中的稳定性与部署难题。结合 Scrapy、Docker、代理中间件与 CI/CD 工具,构建可自动运行、持续迭代的云原生信息提取系统,实现结构化数据采集与标准化交付。
379 1
云原生信息提取系统:容器化流程与CI/CD集成实践

热门文章

最新文章