3.3.3 Controller
Controller是 Controller-runtime的核心结构， 其实现了 Controller的基本逻辑：Controller管理一个工作队列，并从 source.Sources中获取 reconcile.Requests加入队列，通过执行 reconcile.Reconciler来处理队列中的每项 reconcile.Requests，而 reconcile.
Reconciler可以通过读写 Kubernetes 资源来确保集群状态与期望状态一致。
接口：
Controller接口定义在 pkg/controller/controller.go下，包括如下内容。
（1） reconcile.Reconciler：匿名接口，定义了 Reconcile（context.Context，Request）
（Result，error）。
（2） Watch（srcsource.Source，eventhandlerhandler.EventHandler，predicates
...predicate.Predicate）error：定义入队 reconcile.Requests，Watch() 方法会从 sour-ce.Source中获取Event， 并根据参数 Eventhandler来决定如何入队， 根据参数Predicates进行 Event过滤，Preficates可能有多个， 只有所有的 Preficates都返回True 时，才会将 Event 发送给 Eventhandler 处理。
（3） Start（ctxcontext.Context）error：Controller的启动方法，实现了 Controller接口的对象，也实现了Runnable，因此，该方法可以被Manager管理。
（4） GetLogger()logr.Logger：获取 Controller内的 Logger，用于日志输出。
实现：
Controller的实现在 pkg/internal/controller/controller.go下，为结构体 Controller，Controller结构体中包括的主要成员如下。
（1） Namestring：必须设置， 用于标识 Controller，会在 Controller的日志输出中进行关联。
（2） MaxConcurrentReconcilesint：定义允许 reconcile.Reconciler 同时运行的最多个数，默认为 1。
（3） Doreconcile.Reconciler：定义了 Reconcile() 方法，包含了 Controller同步的业务逻辑。Reconcile()能在任意时刻被调用，接收一个对象的 Name与 Namespace，并同步集群当前实际状态至该对象被设置的期望状态。
（4） MakeQueue func() workqueue.RateLimitingInterface：用 于在 Controller启动时，创建工作队列。由于标准的Kubernetes工作队列创建后会立即启动，因此，如果在 Controller启动前就创建队列，在重复调用 controller.New() 方法创建 Con-troller 的情况下，就会导致 Goroutine 泄露。
（5） Queueworkqueue.RateLimitingInterface：使用上面方法创建的工作队列。
（6） SetFieldsfunc（iinterface{}）error：用 于 从 Manager中 获 取 Controller依赖的方法， 依赖包括 Sourcess、EventHandlers和 Predicates等。 此方法存储的是controllerManager.SetFields()方法。
（7） StartedBool：用于表示Controller 是否已经启动。
（8） CacheSyncTimeouttime.Duration：定义了 Cache 完成同步的等待时长，超过时长会被认为是同步失败。默认时长为 2分钟。
（9） startWatches[ ]watchDescription：定 义 了 一 组Watch操 作 的 属 性， 会在Controller启动时， 根据属性进行 Watch操作。watchDescription的定义见代码 清单3-30，watchDescription包括 Event的源 source.Source、Event的入队方法handler.EventHandler以及 Event的过滤方法 predicate.Predicate。
typewatchDescriptionstruct{srcsource.Source
handlerhandler.EventHandlerpredicates[]predicate.Predicate
}
（10） LogLogr.Logger：用于记录日志的日志对象。
Controller的主要逻辑在Controller.Start()方法内，流程如图 3-4所示。
图 3—4Controiier 逻辑
（1） 在Manager调用 Start()方法后，进入 Controller 的启动流程，经过选举等预处理后，Controller进入Start()方法。
（2） Controller根据 MakeQueue() 创建工作队列，并启动工作队列。
（3） Controller根据 startWatches参数启动各个 Watch 流程，并将工作队列注入各个Watcher中。
（4） Controller根据 MaxConcurrentReconciles启动多个 Worker程序，用于处理队列中的对象。
（5） Work程序先从工作队列中获取需要处理的对象，然后调用 Controller成员 Do的 Reconcile()方法进行处理。
（6） 根据 Reconcile() 方法返回的结果， 将对象重新入队列或从队列中删除。重新入队列的方法可以是带有一定延迟的Queue.AddAfter()， 也可以是有限速的 Queue.AddRateLimited()。重新加入的次数无限制。
