如何使用Go Client-go觀看Kubernetes服務事件？

如何使用 Go 用戶端觀看 Kubernetes 服務上的事件

在 Kubernetes 中，監控服務的變更對於維護應用程式的健康至關重要。本文示範如何使用 client-go 函式庫實作 Kubernetes 服務的事件監視。

首先，透過使用 clientcmd.BuildConfigFromFlags() 建立設定物件來建立 Kubernetes 設定：

import (
    "k8s.io/client-go/tools/clientcmd"
)

// ...

config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
    panic(err.Error())
}

import (
    "k8s.io/client-go/kubernetes"
)

// ...

clientset, err := kubernetes.NewForConfig(config)

建立代表您想要的服務的監視清單監視器：

import (
    "k8s.io/client-go/tools/cache"
    v1 "k8s.io/client-go/pkg/api/v1"
)

// ...

watchlist := cache.NewListWatchFromClient(clientset.Core().RESTClient(), "services", v1.NamespaceDefault,
    fields.Everything())

建立一個通知程式來處理傳入的事件：

informer := cache.NewInformer(
    watchlist,
    &v1.Service{},
    time.Second * 0,
    cache.ResourceEventHandlerFuncs{
        AddFunc: func(obj interface{}) {
            fmt.Printf("service added: %s \n", obj)
        },
        DeleteFunc: func(obj interface{}) {
            fmt.Printf("service deleted: %s \n", obj)
        },
        UpdateFunc: func(oldObj, newObj interface{}) {
            fmt.Printf("service changed \n")
        },
    },
)

運行通知程序以開始監視事件：

stop := make(chan struct{})
go informer.Run(stop)

保持程序運行無限期地繼續監控服務事件：

以上是如何使用Go Client-go觀看Kubernetes服務事件？的詳細內容。更多資訊請關注PHP中文網其他相關文章！