利用k8s client-go库创建CRD的informer的操作流程

小蓝

2023 年 12 月 06 日

200 次浏览

暂无评论

3309字数

Linux 技术杂烩

要在 Kubernetes 中使用 client-go 库创建 CRD (Custom Resource Definition) 的 informer，你需要经历以下步骤：

初始化客户端集：
首先，需要初始化用于交互的 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())
}

定义 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 {
    // ...
}

初始化 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)

创建 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{},
)

添加事件处理器：
在 informer 上添加事件处理器可以处理不同的事件，如添加、更新或删除自定义资源。

informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
    AddFunc: func(obj interface{}) {
        // 处理添加资源事件的逻辑
    },
    UpdateFunc: func(oldObj, newObj interface{}) {
        // 处理更新资源事件的逻辑
    },
    DeleteFunc: func(obj interface{}) {
        // 处理删除资源事件的逻辑
    },
})

启动 Informer：
最后，需要启动 informer 并等待接收来自 Kubernetes API 的事件。

stopCh := make(chan struct{})
defer close(stopCh)

// 启动 informer，此操作会运行一个无限循环，在这个循环中监听 API 事件。
go informer.Run(stopCh)

// 等待 informer 停止
<-stopCh

以上步骤将创建一个针对特定 CRD 的 informer，该 informer 会触发相应的事件处理程序以便您对事件进行响应。这是一个高级的方案，需要对 Go 编程语言和 Kubernetes 内部机制有深入的了解。在应用之前，强烈建议深入了解 Kubernetes client-go 库以及其工作原理。