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

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

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

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

1. EventHandler

 

EventHandler(事件句柄)Controller.Watch的参数,当事件产生时,EventHandler将返回对象的 Name和 Namespace,作为 Request被添加到待处理事件队列中。例如,将来自 Source的 PodCreate事件提供给 EnqueueHandler,EventHandler将生成一个Request 添加到队列中,这个 Request包含该 Pod的Name和 Namespace。EventHandler的接口定义在目录 pkg/handler/eventhandler.go下,分别定义了 4类事件加入队列的方式(见代码清单3-38)。

typeEventHandlerinterface{

//定义如何响应Create事件

Create(event.CreateEvent,workqueue.RateLimitingInterface)


//定义如何响应 Update事件

Update(event.UpdateEvent,workqueue.RateLimitingInterface)

 

//定义如何响应Delete事件

Delete(event.DeleteEvent,workqueue.RateLimitingInterface)

 

//定义如何响应Generic事件

Generic(event.GenericEvent,workqueue.RateLimitingInterface)


}

 

在目录pkg/handler/eventhandlergo下,提供了内置的3种 EventHandler接口的实现。

(1)   Funcs:包含4个函数对象类型的成员,分别实现了EventHandler接口的4个方法,开发者根据需要设置 个成员,如果某个成员未设置,默认将对对应的事件不进行反应。

(2)  EnqueueRequestForOwner:将事件中资源对象的Owner加入队列。例如, 因ReplicaSet而创建的 Pod,发送过来的Pod事件被 EnqueueRequestForOwner处理后,加入相应的 ReplicaSet资源队列。

(3)  EnqueueRequestsFromMapFunc:用于自定义资源的映射,是一个私有类,需要通过 EnqueueRequestsFromMapFunc(fnMapFunc)EventHandler方法创建。其中MapFunc是一个函数对象,将一个资源对象映射为多个 reconcile.Request,定义见代码清单 3-39


typeMapFuncfunc(client.Object)[]reconcile.Request

 

EnqueueRequestsFromMapFunc对应 4类事件, 它会将事件中的资源对象取出

(Update会同时取出更改前、更改后的两个资源对象,用MapFunc进行映射,将映射的所有 reconcile.Request加入队列。例如,当集群规模发生变动,导致 Node资源变化时,需要触发 Service进行同步的场景。

EventHandler可以通过 Builder.Watches()方法在创建 Controller时设置,也可以在Controller的Controller.Watch()方法中传入设置。但最终都会传入Source.Start()方法中,用于设置 Source处理事件的逻辑。

EventHandler 主要有以下特性。

(1)  通过将 Request加入队列处理一个或多个对象的事件。

(2)  可以将一个事件映射为另一个相同类型对象的 Request。

(3)  可以将一个事件映射为另一个不同类型对象的 Request例如,将一个 Pod事件映射为一个纳管这个 Pod的 ReplicaSet类型 Request。

(4)  用户应该只使用提供的 Eventhandler实现,而不是使用自定义 Eventhandler实现。

 

2. Source

 

resource.Source(事件源)Controller.Watch的参数。它提供了一个事件流。事件通常来自WatchKubernetesAP(I 如PodCreate、Update、Delete)。例如,source.Kind

为 GroupVersionKind使用了 KubernetesAPI的 Watch端点,以提供 Create、Update、Delete事件。

Source接口定义在目录 pkg/source/source.go下,见代码清单 3-40。

typeSourceinterface{

//Start(是 Controller-runtime的内部⽅法,应该仅由Controller调⽤,⽤于在Informer

中注册EventHandler,将reconcile.Requests加⼊⼯作队列workqueue.RateLimitingInterface

Start(context.Context,handler.EventHandler,workqueue.RateLimitingInterface,

...predicate.Predicate)error

}

 

Source的实现在 pkg/source/source.go下,主要包括 3种。

(1)  Informer:用于提供来自集群内部的事件,例如,PodCreate事件。

(2)   Kind:与 Informer类似 ,也用于提供来自集群内部的事件。不同的是 Informer结构直接继承 cache.Informer,需要开发者自己设置;而 Kind 会根据设置的资源对象类型,自动生成 cache.Informer。

Builder创建 Controller时, 会根据 Builder.For()、Builder.Owns()、Builder.Watches()方法中设置的资源对象类型在Builder.Build() 中创建相应的 Kind,并调用 Controller.Watch()方法将 Kind传入 Controller。

(3)  Channel:用于提供集群外部的事件,例如,GitHubWebHook回调。Channel要求用户连接外部的源(如HttpHandler),以便将GenericEvents写入底层的Channel结构中。

除了以上 3种事件源外,用户还可以实现自己的 Source,如果用户自己实现相应的 Inject接口,Controller会在调用 Watch()方法时, 将依赖注入。其中 Inject接口是Manager为Controller传递依赖的方式,主要定义在目录 pkg/runtime/inject/inject.go下。

 

事件源主要有以下特性。

(1)一般通过 WatchAPI为 Kubernetes对象提供事件流(例如,对象创建、更新和删除)。

(2)用户应该只使用提供的事件源实现,而非使用自定义实现。

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

相关文章
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
1089 0
Android开发中StackOverflowError
Android开发中StackOverflowError错误实例分析 一、概述  我在一个复杂的layout嵌套较多的android界面,碰到了java.lang.StackOverflowError这个Fatal Exception,app程序crash退出。这个错误出现的比较奇怪,在我做技术调研的时候,这个界面是放在单独的一个程序中展示的,工作很正常,没有出现这个严重错误,
958 0
来,你认为应用架构的核心使命是什么? | 开发者必读(053期)
最炫的技术新知、最热门的大咖公开课、最有趣的开发者活动、最实用的工具干货,就在《开发者必读》!
701 0
Hbuilder应用离线本地自定义打包
Hbuilder离校本地Android应用打包
13619 0
安卓开发之ScrollView
当界面不足以将所有的内容显示出来的时候便导致下面的部分内容无法显示出来 所有加上ScrollView 来讲要显示的内容放入之中便可以实现上下滚动界面内容 但是当要显示多个控件的时候会出错  原因是ScrollView只能有一个子控件  解决方法就是 用一个LinearLayout(或者别的布局)...
545 0
人工智能在媒体领域的研究和应用
本文整理自2017云栖大会-成都峰会上华西都市报高级数据产品经理黄传能的分享讲义。讲义主要分享了交互方式对媒体智能化的影响,并分享了,并分享了智能融媒体的探索,封面智能融媒体的实现与多项媒体人工智能方面的实践。
1209 0
【iOS开发】UIScrollView 看不到内容、UIScrollView 不能滑动
初学者第一次使用 UIScrollView 的时候,很可能会遇到 UIScrollView 滑动不了,或者明明添加了内容,却看不到的问题。 这里展示最简洁、最常态化的一种在 UIScrollView 中添加可以滑动的 UIImageView 的案例。
653 0
iOS翻页视图控制器UIPageViewController的应用(一)
iOS翻页视图控制器UIPageViewController的应用
13 0
472
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载