DHorse是一个轻量级、简单易用的云应用管理平台，具有多云和多环境管理、应用管理和部署、服务治理等功能

package org.dhorse.infrastructure.strategy.cluster; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.Reader; import java.math.BigDecimal; import java.math.RoundingMode; import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; import java.util.Base64; import java.util.Base64.Encoder; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import org.dhorse.api.enums.ActionTypeEnum; import org.dhorse.api.enums.AffinityLevelEnum; import org.dhorse.api.enums.ImageSourceEnum; import org.dhorse.api.enums.MessageCodeEnum; import org.dhorse.api.enums.NginxVersionEnum; import org.dhorse.api.enums.NuxtDeploymentTypeEnum; import org.dhorse.api.enums.PackageFileTypeEnum; import org.dhorse.api.enums.ReplicaStatusEnum; import org.dhorse.api.enums.SchedulingTypeEnum; import org.dhorse.api.enums.TechTypeEnum; import org.dhorse.api.enums.YesOrNoEnum; import org.dhorse.api.param.app.env.replica.EnvReplicaPageParam; import org.dhorse.api.param.cluster.ClusterNodePageParam; import org.dhorse.api.param.cluster.namespace.ClusterNamespacePageParam; import org.dhorse.api.response.PageData; import org.dhorse.api.response.model.App; import org.dhorse.api.response.model.AppEnv; import org.dhorse.api.response.model.AppEnv.EnvExtendSpringBoot; import org.dhorse.api.response.model.AppExtendDjango; import org.dhorse.api.response.model.AppExtendFlask; import org.dhorse.api.response.model.AppExtendJava; import org.dhorse.api.response.model.AppExtendNext; import org.dhorse.api.response.model.AppExtendNodejs; import org.dhorse.api.response.model.AppExtendNuxt; import org.dhorse.api.response.model.AppExtendPython; import org.dhorse.api.response.model.ClusterNamespace; import org.dhorse.api.response.model.ClusterNode; import org.dhorse.api.response.model.EnvHealth; import org.dhorse.api.response.model.EnvHealth.Item; import org.dhorse.api.response.model.EnvLifecycle; import org.dhorse.api.response.model.EnvReplica; import org.dhorse.api.response.model.GlobalConfigAgg.ImageRepo; import org.dhorse.api.response.model.GlobalConfigAgg.TraceTemplate; import org.dhorse.infrastructure.model.JsonPatch; import org.dhorse.infrastructure.model.ReplicaMetrics; import org.dhorse.infrastructure.repository.po.AffinityTolerationPO; import org.dhorse.infrastructure.repository.po.AppEnvPO; import org.dhorse.infrastructure.repository.po.AppPO; import org.dhorse.infrastructure.repository.po.ClusterPO; import org.dhorse.infrastructure.strategy.cluster.model.DockerConfigJson; import org.dhorse.infrastructure.strategy.cluster.model.DockerConfigJson.Auth; import org.dhorse.infrastructure.strategy.cluster.model.Replica; import org.dhorse.infrastructure.utils.Constants; import org.dhorse.infrastructure.utils.DeploymentContext; import org.dhorse.infrastructure.utils.DeploymentThreadPoolUtils; import org.dhorse.infrastructure.utils.JsonUtils; import org.dhorse.infrastructure.utils.K8sUtils; import org.dhorse.infrastructure.utils.LogUtils; import org.dhorse.infrastructure.utils.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.util.CollectionUtils; import io.kubernetes.client.Copy; import io.kubernetes.client.Exec; import io.kubernetes.client.KubernetesConstants; import io.kubernetes.client.Metrics; import io.kubernetes.client.PodLogs; import io.kubernetes.client.custom.IntOrString; import io.kubernetes.client.custom.PodMetrics; import io.kubernetes.client.custom.PodMetricsList; import io.kubernetes.client.custom.Quantity; import io.kubernetes.client.custom.V1Patch; import io.kubernetes.client.openapi.ApiClient; import io.kubernetes.client.openapi.ApiException; import io.kubernetes.client.openapi.apis.AppsV1Api; import io.kubernetes.client.openapi.apis.AutoscalingV1Api; import io.kubernetes.client.openapi.apis.CoreV1Api; import io.kubernetes.client.openapi.apis.NetworkingV1Api; import io.kubernetes.client.openapi.models.V1Affinity; import io.kubernetes.client.openapi.models.V1ConfigMapVolumeSource; import io.kubernetes.client.openapi.models.V1Container; import io.kubernetes.client.openapi.models.V1ContainerPort; import io.kubernetes.client.openapi.models.V1ContainerStateTerminated; import io.kubernetes.client.openapi.models.V1ContainerStatus; import io.kubernetes.client.openapi.models.V1CrossVersionObjectReference; import io.kubernetes.client.openapi.models.V1Deployment; import io.kubernetes.client.openapi.models.V1DeploymentList; import io.kubernetes.client.openapi.models.V1DeploymentSpec; import io.kubernetes.client.openapi.models.V1DeploymentStrategy; import io.kubernetes.client.openapi.models.V1EmptyDirVolumeSource; import io.kubernetes.client.openapi.models.V1EnvVar; import io.kubernetes.client.openapi.models.V1ExecAction; import io.kubernetes.client.openapi.models.V1HTTPGetAction; import io.kubernetes.client.openapi.models.V1HTTPIngressPath; import io.kubernetes.client.openapi.models.V1HTTPIngressRuleValue; import io.kubernetes.client.openapi.models.V1HorizontalPodAutoscaler; import io.kubernetes.client.openapi.models.V1HorizontalPodAutoscalerList; import io.kubernetes.client.openapi.models.V1HorizontalPodAutoscalerSpec; import io.kubernetes.client.openapi.models.V1HostPathVolumeSource; import io.kubernetes.client.openapi.models.V1Ingress; import io.kubernetes.client.openapi.models.V1IngressBackend; import io.kubernetes.client.openapi.models.V1IngressList; import io.kubernetes.client.openapi.models.V1IngressRule; import io.kubernetes.client.openapi.models.V1IngressServiceBackend; import io.kubernetes.client.openapi.models.V1IngressSpec; import io.kubernetes.client.openapi.models.V1LabelSelector; import io.kubernetes.client.openapi.models.V1LabelSelectorRequirement; import io.kubernetes.client.openapi.models.V1Lifecycle; import io.kubernetes.client.openapi.models.V1LifecycleHandler; import io.kubernetes.client.openapi.models.V1LocalObjectReference; import io.kubernetes.client.openapi.models.V1Namespace; import io.kubernetes.client.openapi.models.V1NamespaceList; import io.kubernetes.client.openapi.models.V1NodeAffinity; import io.kubernetes.client.openapi.models.V1NodeSelector; import io.kubernetes.client.openapi.models.V1NodeSelectorRequirement; import io.kubernetes.client.openapi.models.V1NodeSelectorTerm; import io.kubernetes.client.openapi.models.V1ObjectMeta; import io.kubernetes.client.openapi.models.V1Pod; import io.kubernetes.client.openapi.models.V1PodAffinity; import io.kubernetes.client.openapi.models.V1PodAffinityTerm; import io.kubernetes.client.openapi.models.V1PodAntiAffinity; import io.kubernetes.client.openapi.models.V1PodCondition; import io.kubernetes.client.openapi.models.V1PodList; import io.kubernetes.client.openapi.models.V1PodSpec; import io.kubernetes.client.openapi.models.V1PodStatus; import io.kubernetes.client.openapi.models.V1PodTemplateSpec; import io.kubernetes.client.openapi.models.V1PreferredSchedulingTerm; import io.kubernetes.client.openapi.models.V1Probe; import io.kubernetes.client.openapi.models.V1ResourceRequirements; import io.kubernetes.client.openapi.models.V1RollingUpdateDeployment; import io.kubernetes.client.openapi.models.V1Secret; import io.kubernetes.client.openapi.models.V1SecretList; import io.kubernetes.client.openapi.models.V1Service; import io.kubernetes.client.openapi.models.V1ServiceBackendPort; import io.kubernetes.client.openapi.models.V1ServiceList; import io.kubernetes.client.openapi.models.V1ServicePort; import io.kubernetes.client.openapi.models.V1ServiceSpec; import io.kubernetes.client.openapi.models.V1Status; import io.kubernetes.client.openapi.models.V1TCPSocketAction; import io.kubernetes.client.openapi.models.V1Toleration; import io.kubernetes.client.openapi.models.V1Volume; import io.kubernetes.client.openapi.models.V1VolumeMount; import io.kubernetes.client.open