2

我想使用 k8s 的客户端库将部署回滚到某个修订版（推出历史记录）。但到目前为止，我还没有找到解决方案。我只能获取资源修订版，但不能获取使用 kebctl 获得的“部署修订版”

kubectl rollout history deployment/nginx_dep

这是使用 client-go api 的代码：

config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)

clientset, err := kubernetes.NewForConfig(config)

dp, err := clientset.ExtensionsV1beta1Client.Deployments("default").Get("nginx-deployment", metav1.GetOptions{})

使用 client-go api：如何获取给定部署的现有修订版。？我想回滚部署以使用此修订版。谁能告诉我应该怎么做？？

这是我项目中的依赖项列表：

[[constraint]]
  name = "k8s.io/client-go"
  version = "3.0.0"

[[override]]
  name = "k8s.io/apimachinery"
  branch = "release-1.6"

先感谢您

4

3 回答 3

1

假设您已经看过更新示例？

无论如何，dp这里的变量包含您需要的所有内容：

dp, err := clientset.ExtensionsV1beta1Client.Deployments("default").Get("nginx-deployment", metav1.GetOptions{})

所以dp是类型v1beta1.Deployment，它包含一个类型的变量，metav1.ObjectMeta它具有ResourceVersion.

于 2017-08-11T13:55:03.890 回答
0 
clientset, err := kubernetes.NewForConfig(config)
deploymentsClient := clientset.AppsV1().Deployments("yournamespace")
result, err := deploymentsClient.Get("yourdeployment", metav1.GetOptions{})
version := result.GetObjectMeta().GetAnnotations()["deployment.kubernetes.io/revision"]
于 2018-11-06T04:34:06.487 回答
0

试试 https://github.com/kubernetes/kubernetes/blob/17fec00b8915dbffac40b9eb481516a66092ef3e/pkg/controller/deployment/rollback.go#L30-L69


import (
    "fmt"

    "github.com/golang/glog"

    "k8s.io/api/core/v1"
    extensions "k8s.io/api/extensions/v1beta1"
    "k8s.io/apimachinery/pkg/types"
    deploymentutil "k8s.io/kubernetes/pkg/controller/deployment/util"
)



func (un *Uninject) rollbackToTemplate(d *v1.Deployment, rs []v1.ReplicaSet) (bool, error) {

    sort.Slice(rs, func(i, j int) bool {
        return rs[i].CreationTimestamp.UnixNano() > rs[j].CreationTimestamp.UnixNano()

    })
    performedRollback := false
    replicaSet := v1.ReplicaSet{}
    for _, r := range rs {
        for _, initContainer := range r.Spec.Template.Spec.InitContainers {
            if initContainer.Name == "istio-init" {
                performedRollback = true
                break
            } else {
                klog.V(4).Infof("Rolling back to a revision that contains the same template as current deployment %q, skipping rollback...", d.Name)
            }
        }
        if len(r.Spec.Template.Spec.InitContainers) == 0 || !performedRollback {
            replicaSet = r
            performedRollback = true
            break
        }
    }
    if performedRollback {
        klog.V(4).Infof("Rolling back deployment %q to template spec %+v", d.Name, replicaSet.Spec.Template.Spec)
        deploymentutil.SetFromReplicaSetTemplate(d, replicaSet.Spec.Template)
        deploymentutil.SetDeploymentAnnotationsTo(d, &replicaSet)
    }
    return performedRollback, un.updateDeploymentAndClearRollbackTo(d)
}

// updateDeploymentAndClearRollbackTo sets .spec.rollbackTo to nil and update the input deployment
// It is assumed that the caller will have updated the deployment template appropriately (in case
// we want to rollback).
func (un *Uninject) updateDeploymentAndClearRollbackTo(d *v1.Deployment) error {
    klog.Infof("Cleans up rollbackTo of deployment %q", d.Name)
    _, err := un.clientSet.AppsV1().Deployments(d.Namespace).Update(context.TODO(), d, metav1.UpdateOptions{})
    return err
}
于 2020-06-16T07:56:34.230 回答