简介、创建deployment有多种方式，如引用创建编排好的yaml文件，然后直接创建，或者在代码内写好需要的文件再进行创建，本文将都举例进行
1、引用本地的yaml文件进行创建，并且更新replicas
package main
import (
"context"
"encoding/json"
"flag"
"fmt"
"io/ioutil"
"path/filepath"
v1 "k8s.io/api/apps/v1"
"k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
yaml "k8s.io/apimachinery/pkg/util/yaml"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/util/homedir"
)
func main() {
// create the clientset
clientset := K8sClient()
var (
err error
data []byte
deployment =&v1.Deployment{}
replicas int32
)
//读取yaml
if data, err = ioutil.ReadFile("C:/Users/72088854/go/src/config"); err != nil {
fmt.Print(err)
}
//yaml转json
if data, err = yaml.ToJSON(data); err != nil {
return
}
//json转struct
if err = json.Unmarshal(data, deployment); err != nil {
return
}
deploymentName := deployment.ObjectMeta.Name
//定义副本的数量
replicas = 4
deployment.Spec.Replicas = &replicas
fmt.Println(deploymentName)
if _, err = clientset.AppsV1().Deployments("default").Get(context.TODO(),deploymentName, metav1.GetOptions{}); err !=nil {
if !errors.IsNotFound(err) {
fmt.Println(err)
return
}
//如果不存在则创建deployment
if _, err = clientset.AppsV1().Deployments("default").Create(context.TODO(), deployment, metav1.CreateOptions{}); err != nil {
fmt.Println(err)
return
}
} else {
//如果存在则更新deployement
if _, err = clientset.AppsV1().Deployments("default").Update(context.TODO(), deployment,metav1.UpdateOptions{}); err != nil {
fmt.Println(err)
return
}
}
fmt.Println("create成功！！！")
}2、代码内书写yaml进行创建
package main
import (
"context"
"flag"
"fmt"
"path/filepath"
v1 "k8s.io/api/apps/v1"
apiv1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/util/homedir"
)
func main() {
// create the clientset
clientset := K8sClient()
var (
err error
deploys =&v1.Deployment{}
)
//json转struct
deployment := &v1.Deployment{
ObjectMeta: metav1.ObjectMeta{
Name: "vc-web",
},
Spec: v1.DeploymentSpec{
Replicas: int32Ptr(2),
Selector: &metav1.LabelSelector{
MatchLabels: map[string]string{
"app": "vc-web",
},
},
Template: apiv1.PodTemplateSpec{
ObjectMeta: metav1.ObjectMeta{
Labels: map[string]string{
"app": "vc-web",
"version": "V1",
},
},
Spec: apiv1.PodSpec{
Containers: []apiv1.Container{
{
Name: "vc-web",
Image: "nginx:1.13.5-alpine",
ImagePullPolicy: "IfNotPresent",
Ports: []apiv1.ContainerPort{
{
Name: "http",
Protocol: apiv1.ProtocolTCP,
ContainerPort: 80,
},
},
},
},
},
},
},
}
cluster := deployment.ObjectMeta.ClusterName
namespace := deployment.ObjectMeta.Namespace
deploymentName := deployment.ObjectMeta.Name
fmt.Println("hello",deploymentName)
if deployment, err = clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Create(context.TODO(), deployment, metav1.CreateOptions{}); err != nil {
fmt.Println(err.Error())
return
}
fmt.Println("create成功！！！")
fmt.Println(cluster, namespace, deploymentName)
}
func int32Ptr(i int32) *int32 {
return &i
}
func K8sClient() *kubernetes.Clientset {
// 使用当前上下文环境
var kubeconfig *string
if home := homedir.HomeDir(); home != "" {
kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
} else {
kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
}
flag.Parse()
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err.Error())
}
// 根据指定的 config 创建一个新的 clientSet
clientSet, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
}
return clientSet
}