使用 Go 客户端观看 Kubernetes 服务事件
问题：
如何监听和接收使用 client-go 在 Kubernetes 中创建、删除或更新服务时发出通知库？
解决方案：
Informer 和 ListWatch
要观看服务事件，我们可以使用来自客户端库。监视列表允许我们创建一个监视程序来监视指定的资源，而通知程序则提供了处理监视过程的更高级别的接口。
以下是如何使用 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 创建一个通知程序，并提供一个事件处理程序列表来处理不同的事件（添加、删除、更新）。在事件处理程序中，当添加、删除或更新服务时，我们会打印相应的消息。最后，我们通过在 goroutine 中运行控制器来启动手表。此代码将持续监控服务事件并打印任何更改的详细信息。
以上是如何使用Go客户端监控Kubernetes服务事件？的详细内容。更多信息请关注PHP中文网其他相关文章！
