在Kubernetes ecosystem中，client-go库是一个强大的集合，它提供了与Kubernetes API进行交互的工具，使得我们可以在自己的应用程序中进行创建、配置以及管理Kubernetes资源。而对于自定义资源的定义（CRD），client-go也提供了informer的机制，此机制能够帮助我们监听资源的变化事件（如创建、更新和删除事件）。
构建一个CRD的Informer涉及以下几个核心步骤：
- 通过CRD定义生成客户端集合：首先，基于CRD定义生成相应的客户端代码。你可能需要使用如k8s.io/code-generator这样的代码生成工具来生成相应的API客户端代码。
- 建立自定义的Informer工厂：然后你需要通过从client-go中导入的工厂模块来建立自定义的Informer工厂实例。这个实例会根据你的自定义资源类型创建一个新的Informer。
- 创建和配置Informer：通过Informer工厂实例来创建Informer，在这个步骤中你可以对Informer进行配置，比如设置同步时间间隔，它决定了Informer多久拉取一次资源的最新状态。
- 设置事件处理程序：一旦Informer被创建，你需要设置资源事件的处理程序（handlers），例如当资源被添加、更新或删除时，你可以注册自定义逻辑来反应这些事件。
- 运行Informer：最后，启动Informer。Informer将在后台运行，并且监听自定义资源的变化，一旦发生变化，它就会调用你为这些事件注册的处理程序。
下面将详细阐述这些步骤。
1. 通过CRD定义生成客户端集合
使用k8s.io/code-generator这样的工具可以自动根据你的CRD定义生成Go语言的客户端库。这样可以为你的自定义资源类型生成类型化的客户端代码，通过这些代码，你可以更为简单地操作Kubernetes中的自定义资源。
2. 建立自定义的Informer工厂
与client-go库中为核心Kubernetes资源提供的Informer相似，你可以为CRD实现自己的Informer工厂。这通常涉及到引用自动生成的客户端集合，并且创建一个新的Informer工厂实例。
例如：
import (
"mycustomclientset "github.com/myorganization/myproject/pkg/client/clientset/versioned"
"k8s.io/client-go/informers"
"k8s.io/client-go/tools/cache"
)
// 使用自定义clientset创建Informer工厂
factory := informers.NewSharedInformerFactory(mycustomclientset, time.Minute*10)
3. 创建和配置Informer
通过Informer工厂，构建出你的CRD资源对应的Informer。
informer := factory.ForResource(myCustomResourceGVR).Informer()
4. 设置事件处理程序
设置用于处理不同事件的回调函数，如添加、更新、删除等。
informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(newObj interface{}) {
// 处理新增资源的逻辑
},
UpdateFunc: func(oldObj, newObj interface{}) {
// 处理更新资源的逻辑
},
DeleteFunc: func(obj interface{}) {
// 处理删除资源的逻辑
},
})
5. 运行Informer
最后，你需要启动Informer，这通常是在你的应用程序的主函数或某个goroutine中完成。
stopCh := make(chan struct{})
defer close(stopCh)
// 启动Informer
go informer.Run(stopCh)
// 等待Informer关闭
<-stopCh
构建并运行Informer之后，你的应用现在能够实时地响应Kubernetes中的CRD资源变化事件。这是一个强大的模式，它可以使得你的应用更加智能地与你的Kubernetes集群互动。通过上述步骤，你可以创建一个强大、可扩展且与Kubernetes紧密集成的系统。
