2.2.8 Controller关于 Client-go典型场景
我们了解了Client-go的各个组件（Reflector、Informer、Indexer），Client-go中包含编写自定义Controller所使用的各种机制，这些机制在 Client-go库中的 Tools包和Util包中进行了定义。在 k8s中，可以利用 Client-go中提供的 Controller机制对所需资源的变化进行监控，根据资源状态的变化进行一系列操作。为加深对前面知识的理解，下面利用 Client-go工具实现一个简单的 Controller。
下面编写一个简易的 Controller，用于监听Pod 创建、删除信息，并将信息打印出来。Controller逻辑如下。
（1） 首先我们需要定义一个 Controller结构体，见代码清单 2-54
typeControllerstruct{
indexercache.Indexer//Indexer的引⽤
queue workqueue.RateLimitingInterface//Workqueue的引⽤
informercache.Controller//Informer的引⽤
}
（2） 初始化一个 Controller，见代码清单 2-55
//将 Workqueue、Informer、Indexer的引⽤作为参数返回⼀个新的Controller
funcNewController(queueworkqueue.RateLimitingInterface,indexercache.Indexer,informercache.Controller)*Controller{
return&Controller{informer:informer,indexer:indexer,queue:queue,
}
}
（3） 定义 Controller的工作流，见代码清单 2-56
func(c*Controller)Run(threadinessint,stopChchanstruct{}){deferruntime.HandleCrash()
deferc.queue.ShutDown()klog.Info("Startingpodcontroller")
//启动 Informer线程，Run函数做两件事情 ：第⼀，运⾏⼀个 Reflector，并从 ListerWatcher
中获取对象的通知放到队列中（DeltaQueue）；第⼆，从队列中取出对象并处理该对象相关业务goc.informer.Run(stopCh)
//等待缓存同步队列
if!cache.WaitForCacheSync(stopCh,c.informer.HasSynced){
runtime.HandleError(fmt.Errorf("Timeoutwaitngforcachestosync"))return
}
//启动多个Worker线程处理Workqueue中的Object
fori:=0;i<threadiness;i++{
gowait.Until(c.runWorker,time.Second,stopCh)
}
<-stopCh
klog.Info("StoppingPodcontroller")
}
