kubernetes - 如何在带有客户端的api.ListOptions中使用 watch -转到kubernetes的客户端SDK

Question

我想用以下代码观看kubernetes集群中 namespace 的变化:

...
log.Infoln("====== 1 ======= ")
namespaces, err := clientset.Namespaces().List(api.ListOptions{Watch: true})
if err != nil {
log.Errorln("Get namespaces from kubernetes cluster error:%v", err)
}
log.Infoln("====== 2 ======= ")
for _, namespace := range namespaces.Items {
log.Println("=======>> namespaces: ", namespace)
}
...

此代码将在namespaces, err := clientset.Namespaces().List(api.ListOptions{Watch: true})处阻止。但是，当我创建新的 namespace 或删除 namespace 时，没有任何响应。
client-go是k8s.io/client-go/1.5/
任何人都可以给我示例代码，谢谢。

Answer 1

我找到了答案:

var watch watch.Interface
if watch, err = clientset.Namespaces().Watch(api.ListOptions{Watch: true}); err != nil {
    log.Errorln("Watch namespaces from kubernetes cluster error:%v", err)
    return
}

eventChan := watch.ResultChan()
for event := range eventChan {
    log.Infoln(event)
}