K8S的client-go与Informer机制

Client-go是Kubernetes的官方Go语言客户端，它提供与Kubernetes集群交互的方法。Informer机制是client-go提供的一种用于监控Kubernetes资源的变化的机制，它可以帮助开发者构建响应式、高效的Kubernetes应用。

以下是一个简单的例子，展示如何使用client-go和Informer机制来监控Kubernetes中的Pods资源变化：

package main
 
import (
    "context"
    "fmt"
    "time"
 
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/fields"
    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/cache"
)
 
func main() {
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
 
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }
 
    watchlist := cache.NewListWatchFromClient(
        clientset.CoreV1().RESTClient(),
        "pods",
        metav1.NamespaceAll,
        fields.Everything(),
    )
 
    store, controller := cache.NewInformer(
        watchlist,
        &corev1.Pod{},
        time.Minute*5,
        cache.ResourceEventHandlerFuncs{
            AddFunc: func(obj interface{}) {
                pod := obj.(*corev1.Pod)
                fmt.Printf("Pod Added: %s\n", pod.Name)
            },
            DeleteFunc: func(obj interface{}) {
                pod := obj.(*corev1.Pod)
                fmt.Printf("Pod Deleted: %s\n", pod.Name)
            },
            UpdateFunc: func(oldObj, newObj interface{}) {
                oldPod := oldObj.(*corev1.Pod)
                newPod := newObj.(*corev1.Pod)
                fmt.Printf("Pod Updated: %s\n", newPod.Name)
            },
        },
    )
 
    stop := make(chan struct{})
    defer close(stop)
    go controller.Run(stop)
 
    // Wait forever
    select {}
}

在这个例子中，我们首先建立了与Kubernetes集群的连接。然后，我们定义了一个ListWatch对象，它负责监听Kubernetes API中的Pods资源。接下来，我们创建了一个Informer，它会启动一个控制器，并且定义了对应的事件处理函数。当Pods有变动时，比如添加、删除或者更新，相应的事件处理函数会被调用。这个例子展示了如何使用Informer机制来监控Kubernetes资源的变化。