1 初始化客户端集：
首先，需要初始化用于交互的 Kubernetes 客户端集。将使用该客户端集来操作 Kubernetes API。
import ("k8s.io/client-go/kubernetes""k8s.io/client-go/rest""k8s.io/client-go/tools/clientcmd"
)// 构建 kubeconfig。在外部集群直接使用 kubeconfig，在集群内使用 Service Account。
kubeconfig, err := clientcmd.BuildConfigFromFlags("", YOUR_KUBECONFIG_PATH)
if err != nil {panic(err.Error())
}// 初始化 Kubernetes 客户端集。
clientset, err := kubernetes.NewForConfig(kubeconfig)
if err != nil {panic(err.Error())
}
2 定义 Custom Resource 的结构：
定义一个 Go 结构来表示 Custom Resource，并确保其实现了 runtime.Object 接口。
import (metav1 "k8s.io/apimachinery/pkg/apis/meta/v1""k8s.io/apimachinery/pkg/runtime"
)// 你的 Custom Resource 的定义，确保它实现了 runtime.Object 接口。
type YourCustomResource struct {metav1.TypeMeta `json:",inline"`metav1.ObjectMeta `json:"metadata,omitempty"`Spec YourCustomResourceSpec `json:"spec"`
}// ...func (in *YourCustomResource) DeepCopyObject() runtime.Object {// ...
}
3 初始化 Scheme 和相应的 CRD Client：
自定义资源需要添加到 Scheme 中。Scheme 是用于操作 API 对象的方法集合，包括序列化、反序列化和版本转换。
import ("k8s.io/client-go/rest""k8s.io/client-go/tools/clientcmd""k8s.io/apimachinery/pkg/runtime""k8s.io/apimachinery/pkg/runtime/schema"
)scheme := runtime.NewScheme()
GroupVersion := schema.GroupVersion{Group: YOUR_GROUP, Version: YOUR_VERSION}// Add your custom resource to the scheme.
scheme.AddKnownTypes(GroupVersion, &YourCustomResource{}, &YourCustomResourceList{})
metav1.AddToGroupVersion(scheme, GroupVersion)config, err := clientcmd.BuildConfigFromFlags("", YOUR_KUBECONFIG_PATH)
if err != nil {panic(err.Error())
}
config.GroupVersion = &GroupVersion
config.APIPath = "/apis"
config.ContentType = runtime.ContentTypeJSON
config.NegotiatedSerializer = serializer.NewCodecFactory(scheme)// 创建 rest 客户端来与 CRD 交云。
restClient, err := rest.RESTClientFor(config)
4 创建 Informer：
Informer 会监听 Kubernetes API 的事件，当你的 Custom Resource 发生变化时（创建、更新或删除），Informer 可以获取到这些事件。
import ("context""k8s.io/client-go/informers""k8s.io/client-go/tools/cache"
)// resyncPeriod 决定 informer 同步资源状态的频率。
resyncPeriod := 30 * time.Second// 初始化自定义资源的 informer
informer := cache.NewSharedIndexInformer(cache.NewListWatchFromClient(restClient, YOUR_RESOURCE_PLURAL, metav1.NamespaceAll, fields.Everything()),&YourCustomResource{},resyncPeriod,cache.Indexers{},
)
5 添加事件处理器：
在 informer 上添加事件处理器可以处理不同的事件，如添加、更新或删除自定义资源。
informer.AddEventHandler(cache.ResourceEventHandlerFuncs{AddFunc: func(obj interface{}) {// 处理添加资源事件的逻辑},UpdateFunc: func(oldObj, newObj interface{}) {// 处理更新资源事件的逻辑},DeleteFunc: func(obj interface{}) {// 处理删除资源事件的逻辑},
})
6 启动 Informer：
最后，需要启动 informer 并等待接收来自 Kubernetes API 的事件。
stopCh := make(chan struct{})
defer close(stopCh)// 启动 informer，此操作会运行一个无限循环，在这个循环中监听 API 事件。
go informer.Run(stopCh)// 等待 informer 停止
<-stopCh
