Go语言开发k8s之Deployment操作解析

1. 结构体

1.1 DeploymentList

所属包："k8s.io/api/apps/v1"

type DeploymentList struct {
    v1.TypeMeta `json:",inline"`
    v1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
    Items           []Deployment `json:"items" protobuf:"bytes,2,rep,name=items"`
}

其中Items的每个成员的结构体Deployment 如下：

1.2 Deployment

所属包："k8s.io/api/apps/v1"

type Deployment struct {
    v1.TypeMeta   `json:",inline"`
    v1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
    Spec              DeploymentSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
    Status            DeploymentStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

其中各成员结构体如下：

1.3 TypeMeta

所属包 "k8s.io/apimachinery/pkg/apis/meta/v1"

type TypeMeta struct {
    Kind       string `json:"kind,omitempty" protobuf:"bytes,1,opt,name=kind"`
    APIVersion string `json:"apiVersion,omitempty" protobuf:"bytes,2,opt,name=apiVersion"`
}

对应k8s的yml文件

apiVersion: apps/v1
kind: Deployment

1.4 ObjectMeta（metadata）

所属包： "k8s.io/apimachinery/pkg/apis/meta/v1"

type ObjectMeta struct {
    Name                       string               `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
    GenerateName               string               `json:"generateName,omitempty" protobuf:"bytes,2,opt,name=generateName"`
    Namespace                  string               `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
    SelfLink                   string               `json:"selfLink,omitempty" protobuf:"bytes,4,opt,name=selfLink"`
    UID                        types.UID            `json:"uid,omitempty" protobuf:"bytes,5,opt,name=uid,casttype=k8s.io/kubernetes/pkg/types.UID"`
    ResourceVersion            string               `json:"resourceVersion,omitempty" protobuf:"bytes,6,opt,name=resourceVersion"`
    Generation                 int64                `json:"generation,omitempty" protobuf:"varint,7,opt,name=generation"`
    CreationTimestamp          Time                 `json:"creationTimestamp,omitempty" protobuf:"bytes,8,opt,name=creationTimestamp"`
    DeletionTimestamp          *Time                `json:"deletionTimestamp,omitempty" protobuf:"bytes,9,opt,name=deletionTimestamp"`
    DeletionGracePeriodSeconds *int64               `json:"deletionGracePeriodSeconds,omitempty" protobuf:"varint,10,opt,name=deletionGracePeriodSeconds"`
    Labels                     map[string]string    `json:"labels,omitempty" protobuf:"bytes,11,rep,name=labels"`
    Annotations                map[string]string    `json:"annotations,omitempty" protobuf:"bytes,12,rep,name=annotations"`
    OwnerReferences            []OwnerReference     `json:"ownerReferences,omitempty" patchStrategy:"merge" patchMergeKey:"uid" protobuf:"bytes,13,rep,name=ownerReferences"`
    Finalizers                 []string             `json:"finalizers,omitempty" patchStrategy:"merge" protobuf:"bytes,14,rep,name=finalizers"`
    ManagedFields              []ManagedFieldsEntry `json:"managedFields,omitempty" protobuf:"bytes,17,rep,name=managedFields"`
}

对应k8s的yml文件中如下部分

metadata:
  ……

和k8s用yml文件创建deployment一样，此处我们主要关心Name和Namespace

1.5 DeploymentSpec（spec）

属于包："k8s.io/api/apps/v1"

type DeploymentSpec struct {
    Replicas                *int32                `json:"replicas,omitempty" protobuf:"varint,1,opt,name=replicas"`
    Selector                *v1.LabelSelector `json:"selector" protobuf:"bytes,2,opt,name=selector"`
    Template                v1.PodTemplateSpec    `json:"template" protobuf:"bytes,3,opt,name=template"`
    Strategy                DeploymentStrategy    `json:"strategy,omitempty" patchStrategy:"retainKeys" protobuf:"bytes,4,opt,name=strategy"`
    MinReadySeconds         int32                 `json:"minReadySeconds,omitempty" protobuf:"varint,5,opt,name=minReadySeconds"`
    RevisionHistoryLimit    *int32                `json:"revisionHistoryLimit,omitempty" protobuf:"varint,6,opt,name=revisionHistoryLimit"`
    Paused                  bool                  `json:"paused,omitempty" protobuf:"varint,7,opt,name=paused"`
    ProgressDeadlineSeconds *int32                `json:"progressDeadlineSeconds,omitempty" protobuf:"varint,9,opt,name=progressDeadlineSeconds"`
}

对应k8s的yml文件中如下部分

spec:
  ……

和k8s用yml文件创建deployment一样，这一部分是我们主要要传入的信息。

1） Replicas（spec.replicas）

一个 int的指针，因此赋值的时候我们只好先定义int变量，在把指针赋给它

2）LabelSelector（spec.selector）

所属包："k8s.io/apimachinery/pkg/apis/meta/v1"

type LabelSelector struct {
    MatchLabels      map[string]string          `json:"matchLabels,omitempty" protobuf:"bytes,1,rep,name=matchLabels"`
    MatchExpressions []LabelSelectorRequirement `json:"matchExpressions,omitempty" protobuf:"bytes,2,rep,name=matchExpressions"`
}

和k8s用yml文件创建deployment一样，我们主要用其中matchLabels打标签：

spec:
  selector:
    matchLabels:
      app: nginx

代码种示例如下

            Selector: &amp;metaV1.LabelSelector{
                MatchLabels: map[string]string{
                    "app": "nginx",
                },
            },

3）PodTemplateSpec（spec.template）

所在包："k8s.io/api/core/v1"

type PodTemplateSpec struct {
    v1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
    Spec              PodSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}

对应k8s的yml文件中如下部分，顾名思义，这一部分定义的是pod的模板。

spec:
  ……
  template:
    ……

4）ObjectMeta （spec.template.metadata）

所在包："k8s.io/apimachinery/pkg/apis/meta/v1"

type ObjectMeta struct {
    Name                       string               `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
    GenerateName               string               `json:"generateName,omitempty" protobuf:"bytes,2,opt,name=generateName"`
    Namespace                  string               `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"`
    SelfLink                   string               `json:"selfLink,omitempty" protobuf:"bytes,4,opt,name=selfLink"`
    UID                        types.UID            `json:"uid,omitempty" protobuf:"bytes,5,opt,name=uid,casttype=k8s.io/kubernetes/pkg/types.UID"`
    ResourceVersion            string               `json:"resourceVersion,omitempty" protobuf:"bytes,6,opt,name=resourceVersion"`
    Generation                 int64                `json:"generation,omitempty" protobuf:"varint,7,opt,name=generation"`
    CreationTimestamp          Time                 `json:"creationTimestamp,omitempty" protobuf:"bytes,8,opt,name=creationTimestamp"`
    DeletionTimestamp          *Time                `json:"deletionTimestamp,omitempty" protobuf:"bytes,9,opt,name=deletionTimestamp"`
    DeletionGracePeriodSeconds *int64               `json:"deletionGracePeriodSeconds,omitempty" protobuf:"varint,10,opt,name=deletionGracePeriodSeconds"`
    Labels                     map[string]string    `json:"labels,omitempty" protobuf:"bytes,11,rep,name=labels"`
    Annotations                map[string]string    `json:"annotations,omitempty" protobuf:"bytes,12,rep,name=annotations"`
    OwnerReferences            []OwnerReference     `json:"ownerReferences,omitempty" patchStrategy:"merge" patchMergeKey:"uid" protobuf:"bytes,13,rep,name=ownerReferences"`
    Finalizers                 []string             `json:"finalizers,omitempty" patchStrategy:"merge" protobuf:"bytes,14,rep,name=finalizers"`
    ManagedFields              []ManagedFieldsEntry `json:"managedFields,omitempty" protobuf:"bytes,17,rep,name=managedFields"`
}

对应k8s的yml文件中如下部分

spec:
  ……
  template:
    metadata:
      creationTimestamp: null
      labels:
        app: nginx

代码中示例如下

                ObjectMeta: metaV1.ObjectMeta{
                    Labels: map[string]string{
                        "app": deploymentName,
                    },
                }

5）Spec（spec.template.spec）

type PodSpec struct {
    Volumes                       []Volume                   `json:"volumes,omitempty" patchStrategy:"merge,retainKeys" patchMergeKey:"name" protobuf:"bytes,1,rep,name=volumes"`
    InitContainers                []Container                `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,20,rep,name=initContainers"`
    Containers                    []Container                `json:"containers" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=containers"`
    EphemeralContainers           []EphemeralContainer       `json:"ephemeralContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,34,rep,name=ephemeralContainers"`
    RestartPolicy                 RestartPolicy              `json:"restartPolicy,omitempty" protobuf:"bytes,3,opt,name=restartPolicy,casttype=RestartPolicy"`
    TerminationGracePeriodSeconds *int64                     `json:"terminationGracePeriodSeconds,omitempty" protobuf:"varint,4,opt,name=terminationGracePeriodSeconds"`
    ActiveDeadlineSeconds         *int64                     `json:"activeDeadlineSeconds,omitempty" protobuf:"varint,5,opt,name=activeDeadlineSeconds"`
    DNSPolicy                     DNSPolicy                  `json:"dnsPolicy,omitempty" protobuf:"bytes,6,opt,name=dnsPolicy,casttype=DNSPolicy"`
    NodeSelector                  map[string]string          `json:"nodeSelector,omitempty" protobuf:"bytes,7,rep,name=nodeSelector"`
    ServiceAccountName            string                     `json:"serviceAccountName,omitempty" protobuf:"bytes,8,opt,name=serviceAccountName"`
    DeprecatedServiceAccount      string                     `json:"serviceAccount,omitempty" protobuf:"bytes,9,opt,name=serviceAccount"`
    AutomountServiceAccountToken  *bool                      `json:"automountServiceAccountToken,omitempty" protobuf:"varint,21,opt,name=automountServiceAccountToken"`
    NodeName                      string                     `json:"nodeName,omitempty" protobuf:"bytes,10,opt,name=nodeName"`
    HostNetwork                   bool                       `json:"hostNetwork,omitempty" protobuf:"varint,11,opt,name=hostNetwork"`
    HostPID                       bool                       `json:"hostPID,omitempty" protobuf:"varint,12,opt,name=hostPID"`
    HostIPC                       bool                       `json:"hostIPC,omitempty" protobuf:"varint,13,opt,name=hostIPC"`
    ShareProcessNamespace         *bool                      `json:"shareProcessNamespace,omitempty" protobuf:"varint,27,opt,name=shareProcessNamespace"`
    SecurityContext               *PodSecurityContext        `json:"securityContext,omitempty" protobuf:"bytes,14,opt,name=securityContext"`
    ImagePullSecrets              []LocalObjectReference     `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,15,rep,name=imagePullSecrets"`
    Hostname                      string                     `json:"hostname,omitempty" protobuf:"bytes,16,opt,name=hostname"`
    Subdomain                     string                     `json:"subdomain,omitempty" protobuf:"bytes,17,opt,name=subdomain"`
    Affinity                      *Affinity                  `json:"affinity,omitempty" protobuf:"bytes,18,opt,name=affinity"`
    SchedulerName                 string                     `json:"schedulerName,omitempty" protobuf:"bytes,19,opt,name=schedulerName"`
    Tolerations                   []Toleration               `json:"tolerations,omitempty" protobuf:"bytes,22,opt,name=tolerations"`
    HostAliases                   []HostAlias                `json:"hostAliases,omitempty" patchStrategy:"merge" patchMergeKey:"ip" protobuf:"bytes,23,rep,name=hostAliases"`
    PriorityClassName             string                     `json:"priorityClassName,omitempty" protobuf:"bytes,24,opt,name=priorityClassName"`
    Priority                      *int32                     `json:"priority,omitempty" protobuf:"bytes,25,opt,name=priority"`
    DNSConfig                     *PodDNSConfig              `json:"dnsConfig,omitempty" protobuf:"bytes,26,opt,name=dnsConfig"`
    ReadinessGates                []PodReadinessGate         `json:"readinessGates,omitempty" protobuf:"bytes,28,opt,name=readinessGates"`
    RuntimeClassName              *string                    `json:"runtimeClassName,omitempty" protobuf:"bytes,29,opt,name=runtimeClassName"`
    EnableServiceLinks            *bool                      `json:"enableServiceLinks,omitempty" protobuf:"varint,30,opt,name=enableServiceLinks"`
    PreemptionPolicy              *PreemptionPolicy          `json:"preemptionPolicy,omitempty" protobuf:"bytes,31,opt,name=preemptionPolicy"`
    Overhead                      ResourceList               `json:"overhead,omitempty" protobuf:"bytes,32,opt,name=overhead"`
    TopologySpreadConstraints     []TopologySpreadConstraint `json:"topologySpreadConstraints,omitempty" patchStrategy:"merge" patchMergeKey:"topologyKey" protobuf:"bytes,33,opt,name=topologySpreadConstraints"`
    SetHostnameAsFQDN             *bool                      `json:"setHostnameAsFQDN,omitempty" protobuf:"varint,35,opt,name=setHostnameAsFQDN"`
    OS                            *PodOS                     `json:"os,omitempty" protobuf:"bytes,36,opt,name=os"`
    HostUsers                     *bool                      `json:"hostUsers,omitempty" protobuf:"bytes,37,opt,name=hostUsers"`
}

对应k8s的yml文件中如下部分，是deployment中pod模板的规格信息

spec:
  ……
  template:
    spec:
      ……

这一部分通常是我们主要填写的，因为内容较多，目前不展开介绍了，以后用到我们再详细说明。
现在我们写一个代码中的简单示例

                Spec: coreV1.PodSpec{
                    Containers: []coreV1.Container{
                        {
                            Name:  deploymentName,
                            Image: image,
                            Ports: []coreV1.ContainerPort{
                                {
                                    ContainerPort: portNum,
                                },
                            },
                        },
                    },
                }

1.6 DeploymentStatus

所在包："k8s.io/api/apps/v1"

type DeploymentStatus struct {
    ObservedGeneration  int64                 `json:"observedGeneration,omitempty" protobuf:"varint,1,opt,name=observedGeneration"`
    Replicas            int32                 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
    UpdatedReplicas     int32                 `json:"updatedReplicas,omitempty" protobuf:"varint,3,opt,name=updatedReplicas"`
    ReadyReplicas       int32                 `json:"readyReplicas,omitempty" protobuf:"varint,7,opt,name=readyReplicas"`
    AvailableReplicas   int32                 `json:"availableReplicas,omitempty" protobuf:"varint,4,opt,name=availableReplicas"`
    UnavailableReplicas int32                 `json:"unavailableReplicas,omitempty" protobuf:"varint,5,opt,name=unavailableReplicas"`
    Conditions          []DeploymentCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,6,rep,name=conditions"`
    CollisionCount      *int32                `json:"collisionCount,omitempty" protobuf:"varint,8,opt,name=collisionCount"`
}

deployment的状态，入门中不必过多关注

1.7 对照yml文件示例

附原生k8s集群上一个deployment 信息，大家可以对照理解一下以上结构体

apiVersion: apps/v1
kind: Deployment
metadata:
  annotations:
    deployment.kubernetes.io/revision: "4"
    field.cattle.io/publicEndpoints: '[{"addresses":["10.10.117.53"],"port":30051,"protocol":"TCP","serviceName":"liubei:nginx","allNodes":true}]'
  creationTimestamp: "2022-09-28T06:07:39Z"
  generation: 6
  name: nginx
  namespace: liubei
  resourceVersion: "19656054"
  selfLink: /apis/apps/v1/namespaces/liubei/deployments/nginx
  uid: dcbf8aac-1c23-4be5-943e-c9f2b3e7c767
spec:
  progressDeadlineSeconds: 600
  replicas: 1
  revisionHistoryLimit: 10
  selector:
    matchLabels:
      app: nginx
  strategy:
    rollingUpdate:
      maxSurge: 25%
      maxUnavailable: 25%
    type: RollingUpdate
  template:
    metadata:
      creationTimestamp: null
      labels:
        app: nginx
    spec:
      containers:
      - image: harbocto.xxx.com.cn/public/nginx:1.19.2-alpine
        imagePullPolicy: Always
        name: nginx
        ports:
        - containerPort: 80
          protocol: TCP
        resources: {}
        terminationMessagePath: /dev/termination-log
        terminationMessagePolicy: File
      dnsPolicy: ClusterFirst
      restartPolicy: Always
      schedulerName: default-scheduler
      securityContext: {}
      terminationGracePeriodSeconds: 30
status:
  availableReplicas: 1
  conditions:
  - lastTransitionTime: "2022-09-28T06:07:44Z"
    lastUpdateTime: "2022-09-28T06:07:44Z"
    message: Deployment has minimum availability.
    reason: MinimumReplicasAvailable
    status: "True"
    type: Available
  - lastTransitionTime: "2022-09-28T06:07:39Z"
    lastUpdateTime: "2022-09-28T13:01:17Z"
    message: ReplicaSet "nginx-b6588447f" has successfully progressed.
    reason: NewReplicaSetAvailable
    status: "True"
    type: Progressing
  observedGeneration: 6
  readyReplicas: 1
  replicas: 1
  updatedReplicas: 1

2. Deployment list

语法

func (DeploymentInterface) List(ctx context.Context, opts v1.ListOptions) (*v1.DeploymentList, error)

语法示例

deploymentList,err = clientSet.AppsV1().Deployments(namespaceName).List(context.TODO(), metaV1.ListOptions{})

完整示例

创建函数

package crowK8S
import (
    "context"
    appsV1 "k8s.io/api/apps/v1"
    metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
)
func GetDeploymentList(clientSet *kubernetes.Clientset,namespaceName string)(deploymentList *appsV1.DeploymentList,err error)  {
    deploymentList,err = clientSet.AppsV1().Deployments(namespaceName).List(context.TODO(), metaV1.ListOptions{})
    if err != nil{
        return nil, err
    }
    return deploymentList, err
}

说明：如果namespaceName 为空字串，则查所有namespace

引用函数

package main
import (
    "fmt"
    "go-k8s/crowK8S"
)
func main()  {
    clientSet,err := crowK8S.ConnectK8s()
    if err !=nil {
        fmt.Println(err)
    }
    deploymentList,err := crowK8S.GetDeploymentList(clientSet,"kube-system")
    if err != nil {
        fmt.Println(err)
    }
    for _,deployment := range deploymentList.Items{
        fmt.Printf("%+v\n",deployment.Name)
    }
}

3. Get Deployment

语法示例

定义函数

package crowK8S
import (
    "context"
    appsV1 "k8s.io/api/apps/v1"
    metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
)
func GetDeployment(clientSet *kubernetes.Clientset,namespaceName string,deploymentName string)(deploymentInfo *appsV1.Deployment,err error)  {
    deploymentInfo,err = clientSet.AppsV1().Deployments(namespaceName).Get(context.TODO(), deploymentName,metaV1.GetOptions{})
    if err != nil{
        return nil, err
    }
    return deploymentInfo, err
}

引用

package main
import (
    "fmt"
    "go-k8s/crowK8S"
)
func main()  {
    clientSet,err := crowK8S.ConnectK8s()
    if err !=nil {
        fmt.Println(err)
    }
    deploymentInfo,err := crowK8S.GetDeployment(clientSet,"kube-system","coredns")
    if err != nil {
        fmt.Println(err)
    }
    fmt.Printf("%+v\n",deploymentInfo)
}

结果输出

说明：打印是一个json字串，以下是我格式化后的结果：

{
    ObjectMeta: {
        coredns kube - system / apis / apps / v1 / namespaces / kube - system / deployments / coredns e6bfc631 - fe3a - 4863 - b202 - a96188c4c3f4 5154836 1 2022 - 07 - 12 16: 41: 38 + 0800 CST < nil > < nil > map[k8s - app: kube - dns] map[deployment.kubernetes.io / revision: 1][][][{
            kubeadm Update apps / v1 2022 - 07 - 12 16: 41: 38 + 0800 CST FieldsV1 {
                "f:metadata": {
                    "f:labels": {
                        ".": {},
                        "f:k8s-app": {}
                    }
                },
                "f:spec": {
                    "f:progressDeadlineSeconds": {},
                    "f:replicas": {},
                    "f:revisionHistoryLimit": {},
                    "f:selector": {},
                    "f:strategy": {
                        "f:rollingUpdate": {
                            ".": {},
                            "f:maxSurge": {},
                            "f:maxUnavailable": {}
                        },
                        "f:type": {}
                    },
                    "f:template": {
                        "f:metadata": {
                            "f:labels": {
                                ".": {},
                                "f:k8s-app": {}
                            }
                        },
                        "f:spec": {
                            "f:containers": {
                                "k:{\"name\":\"coredns\"}": {
                                    ".": {},
                                    "f:args": {},
                                    "f:image": {},
                                    "f:imagePullPolicy": {},
                                    "f:livenessProbe": {
                                        ".": {},
                                        "f:failureThreshold": {},
                                        "f:httpGet": {
                                            ".": {},
                                            "f:path": {},
                                            "f:port": {},
                                            "f:scheme": {}
                                        },
                                        "f:initialDelaySeconds": {},
                                        "f:periodSeconds": {},
                                        "f:successThreshold": {},
                                        "f:timeoutSeconds": {}
                                    },
                                    "f:name": {},
                                    "f:ports": {
                                        ".": {},
                                        "k:{\"containerPort\":53,\"protocol\":\"TCP\"}": {
                                            ".": {},
                                            "f:containerPort": {},
                                            "f:name": {},
                                            "f:protocol": {}
                                        },
                                        "k:{\"containerPort\":53,\"protocol\":\"UDP\"}": {
                                            ".": {},
                                            "f:containerPort": {},
                                            "f:name": {},
                                            "f:protocol": {}
                                        },
                                        "k:{\"containerPort\":9153,\"protocol\":\"TCP\"}": {
                                            ".": {},
                                            "f:containerPort": {},
                                            "f:name": {},
                                            "f:protocol": {}
                                        }
                                    },
                                    "f:readinessProbe": {
                                        ".": {},
                                        "f:failureThreshold": {},
                                        "f:httpGet": {
                                            ".": {},
                                            "f:path": {},
                                            "f:port": {},
                                            "f:scheme": {}
                                        },
                                        "f:periodSeconds": {},
                                        "f:successThreshold": {},
                                        "f:timeoutSeconds": {}
                                    },
                                    "f:resources": {
                                        ".": {},
                                        "f:limits": {
                                            ".": {},
                                            "f:memory": {}
                                        },
                                        "f:requests": {
                                            ".": {},
                                            "f:cpu": {},
                                            "f:memory": {}
                                        }
                                    },
                                    "f:securityContext": {
                                        ".": {},
                                        "f:allowPrivilegeEscalation": {},
                                        "f:capabilities": {
                                            ".": {},
                                            "f:add": {},
                                            "f:drop": {}
                                        },
                                        "f:readOnlyRootFilesystem": {}
                                    },
                                    "f:terminationMessagePath": {},
                                    "f:terminationMessagePolicy": {},
                                    "f:volumeMounts": {
                                        ".": {},
                                        "k:{\"mountPath\":\"/etc/coredns\"}": {
                                            ".": {},
                                            "f:mountPath": {},
                                            "f:name": {},
                                            "f:readOnly": {}
                                        }
                                    }
                                }
                            },
                            "f:dnsPolicy": {},
                            "f:nodeSelector": {
                                ".": {},
                                "f:kubernetes.io/os": {}
                            },
                            "f:priorityClassName": {},
                            "f:restartPolicy": {},
                            "f:schedulerName": {},
                            "f:securityContext": {},
                            "f:serviceAccount": {},
                            "f:serviceAccountName": {},
                            "f:terminationGracePeriodSeconds": {},
                            "f:tolerations": {},
                            "f:volumes": {
                                ".": {},
                                "k:{\"name\":\"config-volume\"}": {
                                    ".": {},
                                    "f:configMap": {
                                        ".": {},
                                        "f:defaultMode": {},
                                        "f:items": {},
                                        "f:name": {}
                                    },
                                    "f:name": {}
                                }
                            }
                        }
                    }
                }
            }
        } {
            kube - controller - manager Update apps / v1 2022 - 08 - 05 16: 36: 43 + 0800 CST FieldsV1 {
                "f:metadata": {
                    "f:annotations": {
                        ".": {},
                        "f:deployment.kubernetes.io/revision": {}
                    }
                },
                "f:status": {
                    "f:availableReplicas": {},
                    "f:conditions": {
                        ".": {},
                        "k:{\"type\":\"Available\"}": {
                            ".": {},
                            "f:lastTransitionTime": {},
                            "f:lastUpdateTime": {},
                            "f:message": {},
                            "f:reason": {},
                            "f:status": {},
                            "f:type": {}
                        },
                        "k:{\"type\":\"Progressing\"}": {
                            ".": {},
                            "f:lastTransitionTime": {},
                            "f:lastUpdateTime": {},
                            "f:message": {},
                            "f:reason": {},
                            "f:status": {},
                            "f:type": {}
                        }
                    },
                    "f:observedGeneration": {},
                    "f:readyReplicas": {},
                    "f:replicas": {},
                    "f:updatedReplicas": {}
                }
            }
        }]
    },
    Spec: DeploymentSpec {
        Replicas: * 2,
        Selector: & v1.LabelSelector {
            MatchLabels: map[string] string {
                k8s - app: kube - dns,
            },
            MatchExpressions: [] LabelSelectorRequirement {},
        },
        Template: {
            {
                0 0001 - 01 - 01 00: 00: 00 + 0000 UTC < nil > < nil > map[k8s - app: kube - dns] map[][][][]
            } {
                [{
                    config - volume {
                        nil nil nil nil nil nil nil nil nil nil nil nil nil nil nil nil nil nil ConfigMapVolumeSource {
                            LocalObjectReference: LocalObjectReference {
                                Name: coredns,
                            },
                            Items: [] KeyToPath {
                                KeyToPath {
                                    Key: Corefile,
                                    Path: Corefile,
                                    Mode: nil,
                                },
                            },
                            DefaultMode: * 420,
                            Optional: nil,
                        }
                        nil nil nil nil nil nil nil nil nil nil
                    }
                }][][{
                    coredns registry.aliyuncs.com / google_containers / coredns: v1 .8 .0[][-conf / etc / coredns / Corefile][{
                        dns 0 53 UDP
                    } {
                        dns - tcp 0 53 TCP
                    } {
                        metrics 0 9153 TCP
                    }][][] {
                        map[memory: {
                            {
                                178257920 0
                            } { < nil >
                            }
                            170 Mi BinarySI
                        }] map[cpu: {
                                {
                                    100 - 3
                                } { < nil >
                                }
                                100 m DecimalSI
                            }
                            memory: {
                                {
                                    73400320 0
                                } { < nil >
                                }
                                70 Mi BinarySI
                            }]
                    }[{
                        config - volume true / etc / coredns < nil >
                    }][] & Probe {
                        ProbeHandler: ProbeHandler {
                            Exec: nil,
                            HTTPGet: & HTTPGetAction {
                                Path: /health,Port:{0 8080 },Host:,Scheme:HTTP,HTTPHeaders:[]HTTPHeader{},},TCPSocket:nil,GRPC:nil,},InitialDelaySeconds:60,TimeoutSeconds:5,PeriodSeconds:10,SuccessThreshold:1,FailureThreshold:5,TerminationGracePeriodSeconds:nil,} &Probe{ProbeHandler:ProbeHandler{Exec:nil,HTTPGet:&HTTPGetAction{Path:/ready,
                                Port: {
                                    0 8181
                                },
                                Host: ,
                                Scheme: HTTP,
                                HTTPHeaders: [] HTTPHeader {},
                            },
                            TCPSocket: nil,
                            GRPC: nil,
                        },
                        InitialDelaySeconds: 0,
                        TimeoutSeconds: 1,
                        PeriodSeconds: 10,
                        SuccessThreshold: 1,
                        FailureThreshold: 3,
                        TerminationGracePeriodSeconds: nil,
                    }
                    nil nil / dev / termination - log File IfNotPresent & SecurityContext {
                        Capabilities: & Capabilities {
                            Add: [NET_BIND_SERVICE],
                            Drop: [all],
                        },
                        Privileged: nil,
                        SELinuxOptions: nil,
                        RunAsUser: nil,
                        RunAsNonRoot: nil,
                        ReadOnlyRootFilesystem: * true,
                        AllowPrivilegeEscalation: * false,
                        RunAsGroup: nil,
                        ProcMount: nil,
                        WindowsOptions: nil,
                        SeccompProfile: nil,
                    }
                    false false false
                }][] Always 0xc000517f88 < nil > Default map[kubernetes.io / os: linux] coredns coredns < nil > false false false < nil > & PodSecurityContext {
                    SELinuxOptions: nil,
                    RunAsUser: nil,
                    RunAsNonRoot: nil,
                    SupplementalGroups: [],
                    FSGroup: nil,
                    RunAsGroup: nil,
                    Sysctls: [] Sysctl {},
                    WindowsOptions: nil,
                    FSGroupChangePolicy: nil,
                    SeccompProfile: nil,
                }[] nil
                default -scheduler[{
                    CriticalAddonsOnly Exists < nil >
                } {
                    node - role.kubernetes.io / master NoSchedule < nil >
                } {
                    node - role.kubernetes.io / control - plane NoSchedule < nil >
                }][] system - cluster - critical < nil > nil[] < nil > < nil > < nil > map[][] < nil > nil < nil >
            }
        },
        Strategy: DeploymentStrategy {
            Type: RollingUpdate,
            RollingUpdate: & RollingUpdateDeployment {
                MaxUnavailable: 1,
                MaxSurge: 25 % ,
            },
        },
        MinReadySeconds: 0,
        RevisionHistoryLimit: * 10,
        Paused: false,
        ProgressDeadlineSeconds: * 600,
    },
    Status: DeploymentStatus {
        ObservedGeneration: 1,
        Replicas: 2,
        UpdatedReplicas: 2,
        AvailableReplicas: 2,
        UnavailableReplicas: 0,
        Conditions: [] DeploymentCondition {
            DeploymentCondition {
                Type: Progressing,
                Status: True,
                Reason: NewReplicaSetAvailable,
                Message: ReplicaSet "coredns-59d64cd4d4"
                has successfully progressed.,
                LastUpdateTime: 2022 - 07 - 12 16: 44: 35 + 0800 CST,
                LastTransitionTime: 2022 - 07 - 12 16: 41: 49 + 0800 CST,
            }, DeploymentCondition {
                Type: Available,
                Status: True,
                Reason: MinimumReplicasAvailable,
                Message: Deployment has minimum availability.,
                LastUpdateTime: 2022 - 08 - 05 16: 36: 39 + 0800 CST,
                LastTransitionTime: 2022 - 08 - 05 16: 36: 39 + 0800 CST,
            },
        },
        ReadyReplicas: 2,
        CollisionCount: nil,
    },
}

4. Create Deployment

语法示例

deployment,err := clientset.AppsV1().Deployments(namespace).Create(context.TODO(),deployment,metaV1.CreateOptions{})

完整示例

yml文件对照

以下是边这个yml文件为例，我们就照着这个内容写代码：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nginx
  namespace: liubei
spec:
  replicas: 1
  selector:
    matchLabels:
      app: nginx
  template:
    metadata:
      labels:
        app: nginx
    spec:
      containers:
      - name: nginx
        image: harbocto.xxx.com.cn/public/nginx
        imagePullPolicy: Always
        ports:
        - containerPort: 80

定义函数

package crowK8S
import (
    "context"
    appsV1 "k8s.io/api/apps/v1"
    coreV1 "k8s.io/api/core/v1"
    metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
)
func CreateSimpleDeployment(clientSet *kubernetes.Clientset,namespaceName string,deploymentName string,image string,portNum int32,replicas int32)(deploymentInfo *appsV1.Deployment,err error)  {
    namespace := namespaceName
    //这个结构和原生k8s启动deployment的yml文件结构完全一样，对着写就好
    deployment := &amp;appsV1.Deployment{
        ObjectMeta: metaV1.ObjectMeta{
            Name: deploymentName,
        },
        Spec: appsV1.DeploymentSpec{
            Replicas: &amp;replicas,
            Selector: &amp;metaV1.LabelSelector{
                MatchLabels: map[string]string{
                    "app":deploymentName,
                },
            },
            Template: coreV1.PodTemplateSpec{
                ObjectMeta: metaV1.ObjectMeta{
                    Labels: map[string]string{
                        "app": deploymentName,
                    },
                },
                Spec: coreV1.PodSpec{
                    Containers: []coreV1.Container{
                        {
                            Name:  deploymentName,
                            Image: image,
                            Ports: []coreV1.ContainerPort{
                                {
                                    ContainerPort: portNum,
                                },
                            },
                        },
                    },
                },
            },
        },
    }
    deploymentInfo,err = clientSet.AppsV1().Deployments(namespace).Create(context.TODO(),deployment,metaV1.CreateOptions{})
    if err != nil {
        return deploymentInfo,err
    }
    return deploymentInfo,nil
}

调用

package main
import (
    "fmt"
    "go-k8s/crowK8S"
)
func main()  {
    clientSet,err := crowK8S.ConnectK8s()
    if err !=nil {
        fmt.Println(err)
    }
    deploymentInfo,err := crowK8S.CreateSimpleDeployment(clientSet,"liubei","nginx","harbocto.xxx.com.cn/public/nginx",80,1)
    if err != nil {
        fmt.Println(err)
    }
    fmt.Printf("%+v\n",deploymentInfo)
}

输出

&Deployment{ObjectMeta:{nginx liubei /apis/apps/v1/namespaces/liubei/deployments/nginx dcbf8aac-1c23-4be5-943e-c9f2b3e7c767 19114656 1 2022-09-28 14:07:39 +0800 CST <nil> <nil> map[] map[] [] [] [{___6go_build_main_go.exe Update apps/v1 2022-09-28 14:07:39 +0800 CST FieldsV1 {"f:spec":{"f:progressDeadlineSeconds":{},"f:replicas":{},"f:revisionHistoryLimit":{},"f:selector":{},"f:strategy":{"f:rollingUpdate":{".":{},"f:maxSurge":{},"f:maxUnavailable":{}},"f:type":{}},"f:template":{"f:metadata":{"f:labels":{".":{},"f:app":{}}},"f:spec":{"f:containers":{"k:{\"name\":\"nginx\"}":{".":{},"f:image":{},"f:imagePullPolicy":{},"f:name":{},"f:ports":{".":{},"k:{\"containerPort\":80,\"protocol\":\"TCP\"}":{".":{},"f:containerPort":{},"f:protocol":{}}},"f:resources":{},"f:terminationMessagePath":{},"f:terminationMessagePolicy":{}}},"f:dnsPolicy":{},"f:restartPolicy":{},"f:schedulerName":{},"f:securityContext":{},"f:terminationGracePeriodSeconds":{}}}}} }]},Spec:DeploymentSpec{Replicas:*1,Selector:&v1.LabelSelector{MatchLabels:map[string]string{app: nginx,},MatchExpressions:[]LabelSelectorRequirement{},},Template:{{ 0 0001-01-01 00:00:00 +0000 UTC <nil> <nil> map[app:nginx] map[] [] [] []} {[] [] [{nginx harbocto.xxx.com.cn/public/nginx [] [] [{ 0 80 TCP }] [] [] {map[] map[]} [] [] nil nil nil nil /dev/termination-log File Always nil false false false}] [] Always 0xc000560040 <nil> ClusterFirst map[] <nil> false false false <nil> PodSecurityContext{SELinuxOptions:nil,RunAsUser:nil,RunAsNonRoot:nil,SupplementalGroups:[],FSGroup:nil,RunAsGroup:nil,Sysctls:[]Sysctl{},WindowsOptions:nil,FSGroupChangePolicy:nil,SeccompProfile:nil,} [] nil default-scheduler [] [] <nil> nil [] <nil> <nil> <nil> map[] [] <nil> nil <nil>}},Strategy:DeploymentStrategy{Type:RollingUpdate,RollingUpdate:&RollingUpdateDeployment{MaxUnavailable:25%,MaxSurge:25%,},},MinReadySeconds:0,RevisionHistoryLimit:*10,Paused:false,ProgressDeadlineSeconds:*600,},Status:DeploymentStatus{ObservedGeneration:0,Replicas:0,UpdatedReplicas:0,AvailableReplicas:0,UnavailableReplicas:0,Conditions:[]DeploymentCondition{},ReadyReplicas:0,CollisionCount:nil,},}

5. PUT Deployment

语法

func (DeploymentInterface) Update(ctx context.Context, deployment *v1.Deployment, opts v1.UpdateOptions) (*v1.Deployment, error)

语法示例

deploymentInfo,err = clientSet.AppsV1().Deployments(namespaceName).Update(context.TODO(),deployment,metaV1.UpdateOptions{})

完整示例（修改镜像）

创建函数

package crowK8S
import (
    "context"
    "fmt"
    appsV1 "k8s.io/api/apps/v1"
    coreV1 "k8s.io/api/core/v1"
    metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
)
func ApplyDeploymentByImage(clientSet *kubernetes.Clientset,namespaceName string,deploymentName string,image string)(deploymentInfo *appsV1.Deployment,err error)  {
    deployment,err := clientSet.AppsV1().Deployments(namespaceName).Get(context.TODO(),deploymentName,metaV1.GetOptions{})
    if err !=nil {
        return deploymentInfo,err
    }
    //deployment.Spec.Replicas = &amp;replicas
    deployment.Spec.Template.Spec.Containers[0].Image = image
    deploymentInfo,err = clientSet.AppsV1().Deployments(namespaceName).Update(context.TODO(),deployment,metaV1.UpdateOptions{})
    if err !=nil {
        return deploymentInfo,err
    }
    return deploymentInfo,nil
}

引用

package main
import (
    "fmt"
    "go-k8s/crowK8S"
)
func main()  {
    clientSet,err := crowK8S.ConnectK8s()
    if err !=nil {
        fmt.Println(err)
    }
    deploymentInfo,err := crowK8S.ApplyDeploymentByImage(clientSet,"liubei","nginx","harbocto.xxx.com.cn/public/nginx:1.19.2-alpine")
    if err != nil {
        fmt.Println(err)
    }
    fmt.Printf("%+v\n",deploymentInfo)
}

输出

&Deployment{ObjectMeta:{nginx liubei /apis/apps/v1/namespaces/liubei/deployments/nginx dcbf8aac-1c23-4be5-943e-c9f2b3e7c767 19190799 4 2022-09-28 14:07:39 +0800 CST <nil> <nil> map[] map[deployment.kubernetes.io/revision:3] [] [] [{___6go_build_main_go.exe Update apps/v1 2022-09-28 14:07:39 +0800 CST FieldsV1 {"f:spec":{"f:progressDeadlineSeconds":{},"f:replicas":{},"f:revisionHistoryLimit":{},"f:selector":{},"f:strategy":{"f:rollingUpdate":{".":{},"f:maxSurge":{},"f:maxUnavailable":{}},"f:type":{}},"f:template":{"f:metadata":{"f:labels":{".":{},"f:app":{}}},"f:spec":{"f:containers":{"k:{\"name\":\"nginx\"}":{".":{},"f:image":{},"f:imagePullPolicy":{},"f:name":{},"f:ports":{".":{},"k:{\"containerPort\":80,\"protocol\":\"TCP\"}":{".":{},"f:containerPort":{},"f:protocol":{}}},"f:resources":{},"f:terminationMessagePath":{},"f:terminationMessagePolicy":{}}},"f:dnsPolicy":{},"f:restartPolicy":{},"f:schedulerName":{},"f:securityContext":{},"f:terminationGracePeriodSeconds":{}}}}} } {kube-controller-manager Update apps/v1 2022-09-28 21:00:18 +0800 CST FieldsV1 {"f:metadata":{"f:annotations":{".":{},"f:deployment.kubernetes.io/revision":{}}},"f:status":{"f:availableReplicas":{},"f:conditions":{".":{},"k:{\"type\":\"Available\"}":{".":{},"f:lastTransitionTime":{},"f:lastUpdateTime":{},"f:message":{},"f:reason":{},"f:status":{},"f:type":{}},"k:{\"type\":\"Progressing\"}":{".":{},"f:lastTransitionTime":{},"f:lastUpdateTime":{},"f:message":{},"f:reason":{},"f:status":{},"f:type":{}}},"f:observedGeneration":{},"f:readyReplicas":{},"f:replicas":{},"f:updatedReplicas":{}}} }]},Spec:DeploymentSpec{Replicas:*1,Selector:&v1.LabelSelector{MatchLabels:map[string]string{app: nginx,},MatchExpressions:[]LabelSelectorRequirement{},},Template:{{ 0 0001-01-01 00:00:00 +0000 UTC <nil> <nil> map[app:nginx] map[] [] [] []} {[] [] [{nginx harbocto.boe.com.cn/public/nginx:1.19.2-alpine [] [] [{ 0 80 TCP }] [] [] {map[] map[]} [] [] nil nil nil nil /dev/termination-log File Always nil false false false}] [] Always 0xc00043a180 <nil> ClusterFirst map[] <nil> false false false <nil> PodSecurityContext{SELinuxOptions:nil,RunAsUser:nil,RunAsNonRoot:nil,SupplementalGroups:[],FSGroup:nil,RunAsGroup:nil,Sysctls:[]Sysctl{},WindowsOptions:nil,FSGroupChangePolicy:nil,SeccompProfile:nil,} [] nil default-scheduler [] [] <nil> nil [] <nil> <nil> <nil> map[] [] <nil> nil <nil>}},Strategy:DeploymentStrategy{Type:RollingUpdate,RollingUpdate:&RollingUpdateDeployment{MaxUnavailable:25%,MaxSurge:25%,},},MinReadySeconds:0,RevisionHistoryLimit:*10,Paused:false,ProgressDeadlineSeconds:*600,},Status:DeploymentStatus{ObservedGeneration:3,Replicas:1,UpdatedReplicas:1,AvailableReplicas:1,UnavailableReplicas:0,Conditions:[]DeploymentCondition{DeploymentCondition{Type:Available,Status:True,Reason:MinimumReplicasAvailable,Message:Deployment has minimum availability.,LastUpdateTime:2022-09-28 14:07:44 +0800 CST,LastTransitionTime:2022-09-28 14:07:44 +0800 CST,},DeploymentCondition{Type:Progressing,Status:True,Reason:NewReplicaSetAvailable,Message:ReplicaSet "nginx-86d45dbbf4" has successfully progressed.,LastUpdateTime:2022-09-28 21:00:18 +0800 CST,LastTransitionTime:2022-09-28 14:07:39 +0800 CST,},},ReadyReplicas:1,CollisionCount:nil,},}

完整示例（修改副本数）

创建函数

func ApplyDeploymentByReplicas(clientSet *kubernetes.Clientset,namespaceName string,deploymentName string,replicas int32)(deploymentInfo *appsV1.Deployment,err error)  {
    deployment,err := clientSet.AppsV1().Deployments(namespaceName).Get(context.TODO(),deploymentName,metaV1.GetOptions{})
    if err !=nil {
        return deploymentInfo,err
    }
    deployment.Spec.Replicas = &replicas
    deploymentInfo,err = clientSet.AppsV1().Deployments(namespaceName).Update(context.TODO(),deployment,metaV1.UpdateOptions{})
    if err !=nil {
        return deploymentInfo,err
    }
    //fmt.Println(err,deployment)
    return deploymentInfo,nil
}

6. Delete Deployment

语法

func (DeploymentInterface) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error

语法示例

err = clientSet.AppsV1().Deployments(namespaceName).Delete(context.TODO(),deploymentName,metaV1.DeleteOptions{})

完整示例

创建函数

package crowK8S
import (
    "context"
    metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
)
func DeleteDeployment(clientSet *kubernetes.Clientset,namespaceName string,deploymentName string)(err error)  {
    err = clientSet.AppsV1().Deployments(namespaceName).Delete(context.TODO(),deploymentName,metaV1.DeleteOptions{})
    if err != nil {
        return err
    }
    return nil
}

调用

import (
    "fmt"
    "go-k8s/crowK8S"
)
func main()  {
    clientSet,err := crowK8S.ConnectK8s()
    if err !=nil {
        fmt.Println(err)
    }
    err = crowK8S.DeleteDeployment(clientSet,"liubei","nginx")
    if err != nil {
        fmt.Println(err)
    }else {
        fmt.Println("删除成功")
    }
}

Go语言开发k8s之Deployment操作解析_Golang

目录

1. 结构体

1.1 DeploymentList

1.2 Deployment

1.3 TypeMeta

1.4 ObjectMeta（metadata）

1.5 DeploymentSpec（spec）

1） Replicas（spec.replicas）

2）LabelSelector（spec.selector）

3）PodTemplateSpec（spec.template）

4）ObjectMeta （spec.template.metadata）

5）Spec（spec.template.spec）

1.6 DeploymentStatus

1.7 对照yml文件示例

2. Deployment list

语法

完整示例

3. Get Deployment

语法示例

4. Create Deployment

语法示例

完整示例

5. PUT Deployment

语法

完整示例（修改镜像）

完整示例（修改副本数）

6. Delete Deployment

语法

完整示例