### 使用 WaitForCacheSync 收集现有 ConfigMap 信息 为了确保 `WaitForCacheSync` 正确工作并收集现有的 ConfigMap 信息，在初始化 Informer 和等待缓存同步时需要注意几个要点。由于 `WaitForCacheSync` 只表示事件已经被分发到 EventHandler，而这些 Handler 是异步执行的[^1]，因此在某些情况下，即使 `WaitForCacheSync` 已经返回 true，实际的数据可能还未完全加载。 下面是一个完整的 Go 示例程序，展示了如何通过 client-go 来设置一个监听特定命名空间下所有 ConfigMaps 的 Informer，并利用 `WaitForCacheSync` 确认初始数据已准备好： ```go package main import ( "context" "flag" "fmt" "time" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes" "k8s.io/client-go/tools/cache" "k8s.io/client-go/util/homedir" "path/filepath" ) func main() { var kubeconfig string if home := homedir.HomeDir(); home != "" { kubeconfig = filepath.Join(home, ".kube", "config") } config, err := kubernetes.ConfigFromFlags(false, kubeconfig) if err != nil { panic(err.Error()) } // 创建 Kubernetes 客户端实例 clientset, err := kubernetes.NewForConfig(config) if err != nil { panic(err.Error()) } // 设置工厂来创建共享 informer factory := informers.NewSharedInformerFactory(clientset, time.Minute*30) // 获取指定命名空间下的 ConfigMap Informer namespace := flag.String("namespace", "", "Namespace of the resource to watch") cmInformer := factory.Core().V1().ConfigMaps().Informer() listerWatcher := cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { return clientset.CoreV1().ConfigMaps(*namespace).List(context.TODO(), options) }, WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { return clientset.CoreV1().ConfigMaps(*namespace).Watch(context.TODO(), options) }, } _, controller := cache.NewInformer( &listerWatcher, &v1.ConfigMap{}, resyncPeriod, cache.ResourceEventHandlerFuncs{ AddFunc: handleAddOrUpdate, UpdateFunc: func(oldObj interface{}, newObj interface{}) { handleAddOrUpdate(newObj) }, }, ) stopper := make(chan struct{}) defer close(stopper) go controller.Run(stopper) // 等待直到缓存同步完成 if !cache.WaitForNamedCacheSync("example-informer", stopper, cmInformer.HasSynced) { fmt.Println("Failed to sync caches.") return } // 缓存同步完成后可以安全地访问配置映射列表 configmaps, err := factory.Core().V1().ConfigMaps().Lister().ConfigMaps(*namespace).List(labels.Everything()) if err != nil { fmt.Printf("Error listing config maps: %v\n", err) return } for i := range configmaps { fmt.Printf("Found ConfigMap with name '%s'\n", configmaps[i].Name) } } // 处理新增或更新的操作 func handleAddOrUpdate(obj interface{}) { configmap := obj.(*v1.ConfigMap) fmt.Printf("Updated/Added ConfigMap: %+v\n", configmap.Name) } ``` 此代码片段定义了一个简单的控制器，它监视给定命名空间中的所有 ConfigMap 对象的变化。当首次启动时，会触发一次全量获取操作以填充本地缓存；之后每当检测到任何更改都会触发相应的回调函数处理新版本的对象。