为了账号安全,请及时绑定邮箱和手机立即绑定

Golang kubernetes go-client 将 Deployment 转换为

Golang kubernetes go-client 将 Deployment 转换为

Go
心有法竹 2022-11-15 10:46:02
我正在创建一个程序,它从 Kubernetes 获取所有部署的列表作为*v1.DeploymentList. 我设法做到了并且有效。然后我对该列表进行一些处理,然后执行许多操作。现在,我有一个新的要求;还需要能够仅提取一个部署并对其应用相同的逻辑。问题是当我使用 get 部署时,我得到*v1.Deployment的当然与*v1.DeploymentList列表不同。现在,这个 DeploymentList 不是切片,所以我不能只使用append也不知道如何转换/转换。作为一个“务实”的解决方案,我试图做的只是将该 Deployment 转换为 DeploymentList,然后将我的其余逻辑仅作为部署应用,因为此时更改其他所有内容都意味着很多负担。我有以下代码:func listK8sDeployments(the_clientset *kubernetes.Clientset, mirrorDeploy *string) *v1.DeploymentList {    if mirrorDeploy != nil {        tmp_deployments, err := the_clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Get(context.TODO(), *mirrorDeploy, metav1.GetOptions{})        if err != nil {            panic(err.Error())        }        // Here would need to convert the *v1.Deployment into *v1.DeploymentList a list to retun it according to my EXISTING logic. If I can do this, I do not need to change anything else on the program.        // return the Deployment list with one single deployment inside and finish.    }    deployments_list, err := the_clientset.AppsV1().Deployments(apiv1.NamespaceDefault).List(context.TODO(), metav1.ListOptions{})    if err != nil {        panic(err.Error())    }    return deployments_list}它返回一个*v1.Deployment,但我需要这个数据作为一个列表,即使*v1.DeploymentList我试图追加它,但*v1.DeploymentList它不是一个切片,所以我不能这样做。关于如何实现这一点或我应该改变做事方式的任何想法?请解释。仅供参考:我也是 Go 和 k8s 相关编程的新手。
查看完整描述

1 回答

?
12345678_0001

TA贡献1802条经验 获得超5个赞

当您查看 v1.DeploymentList 的定义时,您可以看到 Deployment 所在的位置:


// DeploymentList is a list of Deployments.

type DeploymentList struct {

    metav1.TypeMeta `json:",inline"`

    // Standard list metadata.

    // +optional

    metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`


    // Items is the list of Deployments.

    Items []Deployment `json:"items" protobuf:"bytes,2,rep,name=items"`

}


然后您可以轻松地使用您的值创建它的新实例:


func listK8sDeployments(the_clientset *kubernetes.Clientset, mirrorDeploy *string) *v1.DeploymentList {

    if *mirrorDeploy != "" {

        tmp_deployments, err := the_clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Get(context.TODO(), *mirrorDeploy, metav1.GetOptions{})

        if err != nil {

            panic(err.Error())

        }

        // create a new list with your deployment and return it

        deployments_list := v1.DeploymentList{Items: []v1.Deployment{*tmp_deployments}}

        return &deployments_list

    }

    deployments_list, err := the_clientset.AppsV1().Deployments(apiv1.NamespaceDefault).List(context.TODO(), metav1.ListOptions{})

    if err != nil {

        panic(err.Error())

    }

    return deployments_list

}


查看完整回答
反对 回复 2022-11-15
  • 1 回答
  • 0 关注
  • 172 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号