我的做法是：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？
2 回答
ABOUTYOU
TA貢獻1812條經驗 獲得超5個贊
import corev1 "k8s.io/api/core/v1"
// RestartPod deletes a pod marked by a given label
// it then waits for a given timeout for the pod to resume running state
func RestartPod(c *client.ClientSet, label string, timeout time.Duration) error {
pod, err := GetPodByLabel(label)
if err != nil {
return err
}
podUid := pod.UID
err = c.Pods(pod.Namespace).Delete(context.Background(), pod.Name, metav1.DeleteOptions{})
if err != nil {
return err
}
return wait.PollImmediate(5*time.Second, timeout, func() (done bool, err error) {
pod, err := GetPodByLabel(label)
if pod.UID != podUid && err != nil {
return false, nil
}
return pod.Status.Phase == corev1.PodRunning && pod.Status.ContainerStatuses[0].Ready, nil
})
}
- 2 回答
- 0 關注
- 243 瀏覽
添加回答
舉報
0/150
提交
取消