如何使用 Client-go 观察 Kubernetes 中的 CustomResourceDefinitions (CRD)？-Golang-PHP中文网

如何使用 Client-go 观察 Kubernetes 中的 CustomResourceDefinitions (CRD)？

Patricia Arquette

发布： 2024-11-01 18:27:02

原创

683 人浏览过

How to Watch CustomResourceDefinitions (CRDs) in Kubernetes with Client-go?

使用 client-go 观看 CustomResourceDefinitions (CRD)

CustomResourceDefinitions (CRD) 允许用户使用自己的 API 资源扩展 Kubernetes。监视这些资源的变化对于控制器和应用程序至关重要。但是，标准 client-go 库默认情况下无法识别 CRD。

生成自定义客户端

要使用 client-go 监视 CRD，请生成可识别您的特定 CRD 的自定义客户端。这涉及使用 Kubernetes 提供的代码生成工具为 CRD 的 API 创建结构体和客户端。

使用 kubebuilder

生成客户端配置和控制器的推荐方法是使用 kubebuilder。该工具可自动执行代码生成过程，简化自定义客户端的创建。

示例控制器

以下是来自示例控制器的简化代码片段，用于监视 CRD 的更改：

<code class="go">import (
    "github.com/pkg/errors"
    corev1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/labels"
    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/apimachinery/pkg/util/wait"
    "k8s.io/client-go/informers"
    "k8s.io/client-go/kubernetes"
    clientset "k8s.io/client-go/kubernetes/typed/core/v1"
    "k8s.io/client-go/tools/cache"
    "k8s.io/client-go/tools/remotecommand"
)

// watchCRD watches for new/changed CustomResourceDefinitions (CRDs).
func watchCRD() error {
    // Create a new Kubernetes clientset.
    clientset, err := kubernetes.NewForConfig(restConfig)
    if err != nil {
        return errors.WithStack(err)
    }

    // Create an informer for list of CRDs.
    sharedInformerFactory := informers.NewSharedInformerFactory(clientset, 0)
    crdInformer := sharedInformerFactory.ApiextensionsV1().CustomResourceDefinitions().Informer()

    // Initialize the informer and wait for it to sync with API server.
    stopCh := make(chan struct{})
    crdInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
        AddFunc: func(obj interface{}) {
            crd := obj.(*apiextensionsv1.CustomResourceDefinition)
            // Handle newly added CRD.
            fmt.Println("New CRD added:", crd.Name)
        },
        UpdateFunc: func(oldObj, newObj interface{}) {
            crd := newObj.(*apiextensionsv1.CustomResourceDefinition)
            // Handle updated CRD.
            fmt.Println("CRD updated:", crd.Name)
        },
        DeleteFunc: func(obj interface{}) {
            crd := obj.(*apiextensionsv1.CustomResourceDefinition)
            // Handle deleted CRD.
            fmt.Println("CRD deleted:", crd.Name)
        },
    })
    sharedInformerFactory.Start(stopCh)
    <-wait.NeverStop

    return nil
}</code>

登录后复制

在此示例中：