From d062d19940685ea755cc61d758961c8e6c40a48a Mon Sep 17 00:00:00 2001
From: dongming <dongming@dongming-pc>
Date: Mon, 12 Dec 2022 21:25:02 +0800
Subject: [PATCH] l-13

---
 vendor/k8s.io/client-go/tools/cache/reflector.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/vendor/k8s.io/client-go/tools/cache/reflector.go b/vendor/k8s.io/client-go/tools/cache/reflector.go
index d421747..558fed6 100644
--- a/vendor/k8s.io/client-go/tools/cache/reflector.go
+++ b/vendor/k8s.io/client-go/tools/cache/reflector.go
@@ -237,13 +237,14 @@ func (r *Reflector) setExpectedType(expectedType interface{}) {
 // call chains to NewReflector, so they'd be low entropy names for reflectors
 var internalPackages = []string{"client-go/tools/cache/"}
 
+// Reflector 启动的方法，参数 stopCh 是一个信号对象，收到停止信号就退出运行
 // Run repeatedly uses the reflector's ListAndWatch to fetch all the
 // objects and subsequent deltas.
 // Run will exit when stopCh is closed.
 func (r *Reflector) Run(stopCh <-chan struct{}) {
 	klog.V(3).Infof("Starting reflector %s (%s) from %s", r.expectedTypeName, r.resyncPeriod, r.name)
 	wait.BackoffUntil(func() {
-		if err := r.ListAndWatch(stopCh); err != nil {
+		if err := r.ListAndWatch(stopCh); err != nil {// 调用了 list & watch
 			r.watchErrorHandler(r, err)
 		}
 	}, r.backoffManager, true, stopCh)