go - 如何应用 Kubernetes 工作负载

Question

我正在编写一个将在 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 怎么办？

标签： gokubernetes

Answer 1

您需要 Kubernetesclient-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