如何应用kubernetes工作负载

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《如何应用kubernetes工作负载》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我正在编写一个将在 kubernetes 集群中运行的 go 程序。

我希望程序使用 yaml（json 格式的 yaml）应用 kubernetes 工作负载

import (
    "encoding/json"
    "fmt"
    corev1 "k8s.io/api/core/v1"
)
var (
    workload = `{
        "apiVersion": "v1",
        "kind": "Pod",
        "metadata": {
            "name": "sleep",
        },
        "spec": {
            "containers": [
                {
                    "name": "sleep2",
                    "image": "tutum/curl",
                    "command": [
                        "/bin/sleep",
                        "infinity"
                    ],
                    "imagePullPolicy": "Always",
                    "env": [
                        {
                            "name": "ENV_VAR",
                            "value": "i/love/sleeping"
                        }
                    ]
                }
            ]
        }
    }`
)

func ApplyWorkload(){
    pod := corev1.Pod{}
    if err := json.Unmarshal(workload, &pod); err != nil {
        fmt.Errorf("%v", err)
    }
    // apply pod here

}

如何在 go 中应用工作负载？

如果我的工作负载是部署，我该怎么办？我应该为每个可能的工作负载运行一个 switch-case 吗？

解决方案

您需要 kubernetes client-go 来创建 pod 或 deployment。

导入“k8s.io/client-go/kubernetes”

clientset, err := kubernetes.NewForConfig(cfg) // cfg is  the *config 

//    .... ... .. create deployment
result, err := clientset.AppsV1().Deployments(namespaceName).Create(deployment) // deployment object

//    ... .... ... create pod
result, err := clientset.CoreV1().Pods(namespaceName).Create(Pod) // Pod object

理论要掌握，实操不能落！以上关于《如何应用kubernetes工作负载》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！