Go 클라이언트를 사용하여 Kubernetes 서비스 이벤트를 모니터링하는 방법은 무엇입니까?

Go 클라이언트로 Kubernetes 서비스 이벤트 시청

문제:

모니터링 및 수신 방법 client-go를 사용하여 Kubernetes에서 서비스가 생성, 삭제 또는 업데이트될 때 알림 라이브러리?

해결책:

Informer 및 ListWatch

서비스 이벤트를 시청하려면 다음에서 Watchlist 및 Informer를 사용할 수 있습니다. 클라이언트 이동 라이브러리. 감시 목록을 사용하면 지정된 리소스를 모니터링하는 감시자를 생성할 수 있고, 정보 제공자는 감시 프로세스를 처리하는 상위 수준 인터페이스를 제공합니다.

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)
    }
}

설명:

우리가 먼저 NewListWatchFromClient를 사용하여 관심 목록을 생성하고 리소스 유형(서비스), 네임스페이스(기본값) 및 필드 선택기(모두)를 지정합니다. 그런 다음 NewInformer를 사용하여 정보 제공자를 만들고 다양한 이벤트(추가, 삭제, 업데이트)를 처리하는 이벤트 핸들러 목록을 제공합니다. 이벤트 핸들러 내에서는 서비스가 추가, 삭제 또는 업데이트될 때 적절한 메시지를 인쇄합니다. 마지막으로 고루틴에서 컨트롤러를 실행하여 시계를 시작합니다. 이 코드는 서비스 이벤트를 지속적으로 모니터링하고 변경 사항에 대한 세부 정보를 인쇄합니다.

위 내용은 Go 클라이언트를 사용하여 Kubernetes 서비스 이벤트를 모니터링하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!