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 중국어 웹사이트의 기타 관련 기사를 참조하세요!