kubernetes1.9源码阅读 kubernetes的watch包

要理解kubernetes的list-watch机制,首先应该熟悉理解kubernetes的watch包中的各种实现以及原理。这篇文章将从代码实现看看kubernetes的watch包实现。从kubernetes1.6之后,kubernetes的watch包抽取到了apimachinery这个项目下。

watch包文件说明

watch包主要包含5个文件:watch.go,mux.go,filter.go,streamwatch.go,util.go。下面是对这五个文件作简单的说明:

1. watch.go 主要是接口定义及对interface的三种实现的封装。

2. mux.go 主要是事件广播器。

3. filter.go 主要是对事件的过滤。

4. streamwatch.go 主要是对decoder接口实现的封装。

5. util.go 主要是对满足条件时间的过滤。

watch.go文件

watch.go定义了接口,k8s中说有的event事件统一都实现了interface接口,interface接口的定义如下:

1. Event结构体,主要包括:事件类型Type和事件发生的对象Object,k8s中所有的对象(比如:pod、service、rc、dp….)都是runtime.Object;

2. watch.Interface中主要有两个方法:分别是对事件的监听结果ResultChan()和停止监听Stop()方法;

3. watch.go还包括对Interface的三种实现的封装:emptyWatch、fakerWatch

、racefreeWatch,fakerWatch和racefreeWatch是线程安全的;

mux.go文件

mux.go文件中主要包括了事件广播器Broadcaster和广播器的观察者broadcasterWatcher;

1. Broadcaster包括watchers,当创建一个Broadcaster时,Broadcaster会开一个协程接收所有的事件及发送事件到所有注册的watcher。保证Broadcaster的所有的watcher一直都能不断的接收到Broadcaster发送过来的事件;

2. broadcastWatcher实现了watch.Interface,包括:resultChan方法和stop方法;

3. 在kube-scheduler中,会创建record.NewBroadcaster(),发送event到logging函数,参见之前的文章:kubernetes1.8 kube-scheduler源码阅读

filter.go文件

filter.go文件也是主要对interface的的实现,加上了事件过滤的方法,这样的话,就可以只watcher满足一定条件的事件了;

同时,filter.go中的Recorder结构体,记录watcher所接收到的所有的事件;