要理解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所接收到的所有的事件；

作者：范彬2017
链接：https://www.jianshu.com/p/d0329668f34c