Wie überwache ich Kubernetes-Dienstereignisse mit dem Go-Client?

Beobachten von Kubernetes-Serviceereignissen mit dem Go-Client

Problem:

Wie man überwacht und empfängt Benachrichtigungen, wenn ein Dienst in Kubernetes mithilfe des Client-Go erstellt, gelöscht oder aktualisiert wird Bibliothek?

Lösung:

Informer und ListWatch

Um Serviceereignisse zu beobachten, können wir Watchlist und Informer aus der Bibliothek verwenden Client-Go-Bibliothek. Mit einer Beobachtungsliste können wir einen Beobachter erstellen, um bestimmte Ressourcen zu überwachen, während ein Informer eine übergeordnete Schnittstelle bereitstellt, die den Überwachungsprozess abwickelt.

So überwachen Sie Serviceereignisse mit client-go:

package main

import (
    "fmt"
    "flag"
    "time"

    k8sclient "k8s.io/client-go/kubernetes"
    corev1 "k8s.io/client-go/pkg/api/v1"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/tools/cache"
    "k8s.io/client-go/pkg/fields"
)

func main() {
    var kubeconfig = flag.String("kubeconfig", "./config", "path to the kubeconfig file")
    flag.Parse()

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

    clientset, err := k8sclient.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }

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

    _, controller := cache.NewInformer(
        watchlist,
        &corev1.Service{},
        time.Second * 0,
        cache.ResourceEventHandlerFuncs{
            AddFunc: func(obj interface{}) {
                fmt.Printf("Service added: %v\n", obj)
            },
            DeleteFunc: func(obj interface{}) {
                fmt.Printf("Service deleted: %v\n", obj)
            },
            UpdateFunc: func(oldObj, newObj interface{}) {
                fmt.Printf("Service updated: %v\n", oldObj)
            },
        },
    )

    stop := make(chan struct{})
    go controller.Run(stop)
    for {
        time.Sleep(time.Second)
    }
}

Erklärung:

Wir erstellen zunächst eine Watchlist mit NewListWatchFromClient mit Angabe des Ressourcentyps (Dienste), des Namespace (Standard) und der Feldauswahl (alles). Anschließend erstellen wir mit NewInformer einen Informer und stellen eine Liste von Ereignishandlern zur Verfügung, die die verschiedenen Ereignisse (Hinzufügen, Löschen, Aktualisieren) verarbeiten. Innerhalb der Event-Handler geben wir die entsprechende Meldung aus, wenn ein Dienst hinzugefügt, gelöscht oder aktualisiert wird. Schließlich starten wir die Uhr, indem wir den Controller in einer Goroutine ausführen. Dieser Code überwacht kontinuierlich Serviceereignisse und druckt die Details aller Änderungen aus.

Das obige ist der detaillierte Inhalt vonWie überwache ich Kubernetes-Dienstereignisse mit dem Go-Client?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!