要理解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所接收到的所有的事件；
相关阅读：
1. http://blog.csdn.net/u013812710/
