我的做法是:
func restartPod(meta metav1.ObjectMeta, kubeClient kubernetes.Interface) error {
err := kubeClient.CoreV1().Pods(meta.Namespace).Delete(meta.Name, deleteInForeground())
if err != nil {
return err
}
//time.Sleep(2 * time.Second)
return wait.PollImmediate(5*time.Second, 5*time.Minute, func() (done bool, err error) {
pod, err := kubeClient.CoreV1().Pods(meta.Namespace).Get(meta.Name, metav1.GetOptions{})
if err != nil {
return false, nil
}
return pod.Status.Phase == v1.PodRunning && pod.Status.ContainerStatuses[0].Ready, nil
})
}
它不起作用,因为 pod 的删除是非阻塞的,意味着它不会等待 pod 被删除。因此Getpod 方法返回处于运行状态的 pod。如果我sleep在 pod 删除后使用几秒钟,那么它就可以正常工作。有没有更好的方法来做到这一点而不使用sleep?
尚方宝剑之说
ABOUTYOU
相关分类