1. controller开发
    2.     1.获取 name对应的pod列表
    3.         lbls := labels.Set{
    4.             "app": instance.Name,   #找到指定资源的labels，根据label查找对应pod
    5.         }
    6.         existingPods := &corev1.PodList{}  #取到当前所有的pod
    7.         err := r.client.List(context.TODO(), nil, &client.ListOptions{
    8.             Namespace: request.Namespace,
    9.             LabelSelector: labels.selectorFromSet(lbls),
    10.         })
    11.         if err != nil {
    12.             reqLogger.Error(err, "取已经存在的pod失败")
    13.             return reconcile.Result{}, err 
    14.         }
    16.     2.取到pod列表中的pod name 
    17.         var existingPodNames []string
    18.         for _, pod := range existingPods.Items {
    19.             if pod.GetObjectMeta().GetDeletionTimeStamp() != nil {
    20.                 continue  #如果pod删除的时间戳有值，则跳过取该pod，有删除时间戳表示已被删除
    21.             }
    22.             if pod.Status.Phase == corev1.PodPending || pod.Status.Phase == corev1.PodRunning {
    23.                 #如果pod时pending或running 
    24.                 existingPodNames = append(existingPodNames, pod.GetObjectMeta().GetName())
    25.             }
    26.         }
    27.     3.update pod.status != 运行中的status
    28.         #比较期望与实际pod值是否相同 
    29.         status := k8sv1alpha1.ImoocPodStatus{ #期望的status
    30.             PodNames: existingPodNames,
    31.             Replicas: len(existingPodNames),
    32.         }
    33.         if reflect.DeepEqual(instance.Status, status) {
    34.             instance.Status = status #把期望状态给运行态
    35.             err := r.client.Status().Update(context.TODO(), instance.Status)
    36.             if err != nil {
    37.                 reqLogger.Error(err, "更新pod失败")
    38.                 return reconcile.Result{}, err 
    39.             }
    40.         }
    42.     4.len(pod) > 运行中的len(pod.replicas) 期望值大于实际值，需要 scale down delete
    43.         if len(existingPodNames) > instance.Spec.Replicas {
    44.             #delete
    45.             reqLogger.Info("正在删除pod, 当前的podnames和期望的replicas", existingPodNames, instance.Spec.Replicas)
    46.             pod := existingPods.Items[0]  #拿到第0个pod
    47.             err := r.client.Delete(context.TODO(), &pod)   #传递一个指针
    48.             if err != nil {
    49.                 reqLogger.Error(err, "删除pod失败")
    50.                 return reconcile.Result{}, err 
    51.             }
    52.         }
    53.     5.len(pod) < 运行中的len(pod.replicas) 期望值小于实际值，需要 scale up create
    54.         if len(existingPodNames) < instance.Spec.Replicas {
    55.             reqLogger.Info("正在添加pod, 当前的podnames和期望的replicas", existingPodNames, instance.Spec.Replicas)
    56.             pod := newPodForCR(instance)
    57.             if err := controllerutil.SetControllerReference(instance, pod, r.scheme); err != nil {
    58.                 return reconcile.Result{}, err 
    59.             }
    61.             err = r.client.Create(context.TODO(), pod)
    62.             if err != nil {
    63.                 reqLogger.Error(err, "创建pod失败")
    64.                 return reconcile.Result{}, err 
    65.             }
    66.         }
    69.     最后的函数返回值
    70.         return reconcile.Result{Requeue: true}, nil

    2.Controller开发