watch, err := clientSet.AppsV1().Deployments("default").Watch(context.TODO(), met*1.ListOptions{
    FieldSelector: "metadata.name=my-deployment",
})
if err != nil {
    log.Fatal(err)
}
<p>for event := range watch.ResultChan() {
if deployment, ok := event.Object.(*appsv1.Deployment); ok {
updated := deployment.Status.UpdatedReplicas
total := deployment.Status.Replicas
ready := deployment.Status.ReadyReplicas</p><pre class='brush:php;toolbar:false;'>    if updated == total && ready == total {
        log.Println("滚动更新完成")
    } else {
        log.Printf("更新中: %d/%d 已更新, %d 就绪", updated, total, ready)
    }
}

}

deployment, err := clientSet.AppsV1().Deployments("default").Get(context.TODO(), "my-deployment", met*1.GetOptions{})
if err != nil {
    log.Fatal(err)
}
<p>// 更新容器镜像
deployment.Spec.Template.Spec.Containers[0].Image = "my-image:v2"</p><p>_, err = clientSet.AppsV1().Deployments("default").Update(context.TODO(), deployment, met*1.UpdateOptions{})
if err != nil {
log.Fatal(err)
}
log.Println("Deployment已更新，滚动更新开始")</p>

for {
    dep, _ := clientSet.AppsV1().Deployments("default").Get(context.TODO(), "my-deployment", met*1.GetOptions{})
    if dep.Status.UpdatedReplicas == *dep.Spec.Replicas &&
       dep.Status.ReadyReplicas == *dep.Spec.Replicas {
        log.Println("更新成功")
        break
    }
    time.Sleep(2 * time.Second)
}

for _, cond := range deployment.Status.Conditions {
    if cond.Type == appsv1.DeploymentProgressing && cond.Status == corev1.ConditionFalse {
        log.Printf("更新失败: %s", cond.Reason)
        // 可选择回滚
    }
}