带你读《云原生应用开发 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()方法。

相关文章
|
27天前
|
Cloud Native 数据处理 云计算
探索云原生技术在大数据分析中的应用
随着云计算技术的不断发展,云原生架构作为一种全新的软件开发和部署模式,正逐渐引起企业的广泛关注。本文将探讨云原生技术在大数据分析领域的应用,介绍其优势与挑战,并探讨如何利用云原生技术提升大数据分析的效率和可靠性。
|
1月前
|
缓存 Java API
【云原生】Spring Cloud Gateway的底层原理与实践方法探究
【云原生】Spring Cloud Gateway的底层原理与实践方法探究
|
1月前
|
Kubernetes Cloud Native 开发工具
带你读《云原生应用开发:Operator原理与实践》精品文章合集
带你读《云原生应用开发:Operator原理与实践》精品文章合集
|
2月前
|
人工智能 缓存 Kubernetes
.NET 9 首个预览版发布:瞄准云原生和智能应用开发
.NET 9 首个预览版发布:瞄准云原生和智能应用开发
|
29天前
|
Cloud Native 安全 持续交付
构建未来:云原生架构的演进与实践
【2月更文挑战第30天】 随着数字化转型的深入,企业对于信息技术的需求日益复杂化和动态化。传统的IT架构已难以满足快速迭代、灵活扩展及成本效率的双重要求。云原生技术作为解决这一矛盾的关键途径,通过容器化、微服务、持续集成/持续部署(CI/CD)等手段,实现了应用的快速开发、部署及运维。本文将探讨云原生架构的最新发展,分析其如何助力企业构建更加灵活、高效的业务系统,并结合实际案例,展示云原生转型过程中的最佳实践和面临的挑战。
|
6天前
|
Kubernetes 监控 Cloud Native
构建高效云原生应用:基于Kubernetes的微服务治理实践
【4月更文挑战第13天】 在当今数字化转型的浪潮中,企业纷纷将目光投向了云原生技术以支持其业务敏捷性和可扩展性。本文深入探讨了利用Kubernetes作为容器编排平台,实现微服务架构的有效治理,旨在为开发者和运维团队提供一套优化策略,以确保云原生应用的高性能和稳定性。通过分析微服务设计原则、Kubernetes的核心组件以及实际案例,本文揭示了在多变的业务需求下,如何确保系统的高可用性、弹性和安全性。
11 4
|
21天前
|
Java fastjson 数据安全/隐私保护
【Dubbo3技术专题】「云原生微服务开发实战」 一同探索和分析研究RPC服务的底层原理和实现
【Dubbo3技术专题】「云原生微服务开发实战」 一同探索和分析研究RPC服务的底层原理和实现
38 0
|
29天前
|
运维 Cloud Native 持续交付
云原生技术的未来展望:如何塑造下一代应用开发
【2月更文挑战第30天】 随着云计算的不断发展,云原生技术已经成为推动现代应用开发的重要力量。本文将深入探讨云原生技术的核心概念,分析其在提高开发效率、降低运维成本以及支持复杂业务场景中的作用。同时,文章还将预测云原生技术的发展趋势,并讨论如何在不断变化的技术环境中保持应用的敏捷性和可靠性。
|
1月前
|
消息中间件 存储 Cloud Native
【Spring云原生系列】Spring RabbitMQ:异步处理机制的基础--消息队列 原理讲解+使用教程
【Spring云原生系列】Spring RabbitMQ:异步处理机制的基础--消息队列 原理讲解+使用教程
|
2月前
|
Prometheus 监控 Kubernetes
青团社:亿级灵活用工平台的云原生架构实践
青团社:亿级灵活用工平台的云原生架构实践
262339 5

热门文章

最新文章