我正在 k8 客户端创建一个 pod,并制作一个手表以在 pod 完成时收到通知,以便我可以读取 pod 的日志。手表界面似乎没有提供频道上的任何事件。这是代码,我将如何收到 pod 状态现已完成并准备好读取日志的通知
func readLogs(clientset *kubernetes.Clientset) {
// namespace := "default"
// label := "cithu"
var (
pod *v1.Pod
// watchface watch.Interface
err error
)
// returns a pod after creation
pod, err = createPod(clientset)
fmt.Println(pod.Name, pod.Status, err)
if watchface, err = clientset.CoreV1().Pods(namespace).Watch(metav1.ListOptions{
LabelSelector: pod.Name,
}); err != nil {
log.Fatalf(err.Error())
}
// How do I get notified when the pod.Status == completed
}