From 7dbca5df34d5943f3a06fb79915743ad86a3bc50 Mon Sep 17 00:00:00 2001 From: Hang Yan Date: Sun, 5 Jan 2020 21:36:32 +0800 Subject: [PATCH] Fix some ci lint (#1233) --- pkg/kobject/kobject.go | 7 ++++--- pkg/transformer/kubernetes/k8sutils.go | 14 +++++++------- pkg/transformer/openshift/openshift.go | 2 +- pkg/transformer/utils.go | 2 +- 4 files changed, 13 insertions(+), 12 deletions(-) diff --git a/pkg/kobject/kobject.go b/pkg/kobject/kobject.go index 1ca950ed..8005af8b 100644 --- a/pkg/kobject/kobject.go +++ b/pkg/kobject/kobject.go @@ -175,7 +175,7 @@ type Volumes struct { SelectorValue string // Value of the label selector } -// GetConfigMapKeyFromMeta... +// GetConfigMapKeyFromMeta ... // given a source name ,find the file and extract the filename which will be act as ConfigMap key // return "" if not found func (s *ServiceConfig) GetConfigMapKeyFromMeta(name string) (string, error) { @@ -195,7 +195,7 @@ func (s *ServiceConfig) GetConfigMapKeyFromMeta(name string) (string, error) { } -// GetUpdateStrategy from compose update_config +// GetKubernetesUpdateStrategy from compose update_config // 1. only apply to Deployment, but the check is not happened here // 2. only support `parallelism` and `order` // return nil if not support @@ -222,7 +222,8 @@ func (s *ServiceConfig) GetKubernetesUpdateStrategy() *extensions.RollingUpdateD } -func (s *ServiceConfig) GetOCUpdateStrategy() *deployapi.RollingDeploymentStrategyParams { +// GetOSUpdateStrategy ... +func (s *ServiceConfig) GetOSUpdateStrategy() *deployapi.RollingDeploymentStrategyParams { config := s.DeployUpdateConfig r := deployapi.RollingDeploymentStrategyParams{} diff --git a/pkg/transformer/kubernetes/k8sutils.go b/pkg/transformer/kubernetes/k8sutils.go index 9c3d9d1b..9d8a1339 100644 --- a/pkg/transformer/kubernetes/k8sutils.go +++ b/pkg/transformer/kubernetes/k8sutils.go @@ -588,6 +588,7 @@ func (k *Kubernetes) UpdateKubernetesObjects(name string, service kobject.Servic return nil } +// TranslatePodResource config pod resources func TranslatePodResource(service *kobject.ServiceConfig, template *api.PodTemplateSpec) { // Configure the resource limits if service.MemLimit != 0 || service.CPULimit != 0 { @@ -623,6 +624,7 @@ func TranslatePodResource(service *kobject.ServiceConfig, template *api.PodTempl } +// GetImagePullPolicy get image pull settings func GetImagePullPolicy(name, policy string) (api.PullPolicy, error) { switch policy { case "": @@ -639,6 +641,7 @@ func GetImagePullPolicy(name, policy string) (api.PullPolicy, error) { } +// GetRestartPolicy ... func GetRestartPolicy(name, restart string) (api.RestartPolicy, error) { switch restart { case "", "always", "any": @@ -694,7 +697,7 @@ func (k *Kubernetes) RemoveDupObjects(objs *[]runtime.Object) { *objs = result } -func resetWorkloadApiVersion(d runtime.Object) runtime.Object { +func resetWorkloadAPIVersion(d runtime.Object) runtime.Object { data, err := json.Marshal(d) if err == nil { var us runtime.Unstructured @@ -705,12 +708,9 @@ func resetWorkloadApiVersion(d runtime.Object) runtime.Object { Kind: d.GetObjectKind().GroupVersionKind().Kind, }) return &us - } else { - return d } - } else { - return d } + return d } // FixWorkloadVersion force reset deployment/daemonset's apiversion to apps/v1 @@ -718,10 +718,10 @@ func (k *Kubernetes) FixWorkloadVersion(objs *[]runtime.Object) { var result []runtime.Object for _, obj := range *objs { if d, ok := obj.(*extensions.Deployment); ok { - nd := resetWorkloadApiVersion(d) + nd := resetWorkloadAPIVersion(d) result = append(result, nd) } else if d, ok := obj.(*extensions.DaemonSet); ok { - nd := resetWorkloadApiVersion(d) + nd := resetWorkloadAPIVersion(d) result = append(result, nd) } else { result = append(result, obj) diff --git a/pkg/transformer/openshift/openshift.go b/pkg/transformer/openshift/openshift.go index 9c3b992f..7539212b 100644 --- a/pkg/transformer/openshift/openshift.go +++ b/pkg/transformer/openshift/openshift.go @@ -233,7 +233,7 @@ func (o *OpenShift) initDeploymentConfig(name string, service kobject.ServiceCon }, } - update := service.GetOCUpdateStrategy() + update := service.GetOSUpdateStrategy() if update != nil { dc.Spec.Strategy = deployapi.DeploymentStrategy{ Type: deployapi.DeploymentStrategyTypeRolling, diff --git a/pkg/transformer/utils.go b/pkg/transformer/utils.go index a4242dc5..51820422 100644 --- a/pkg/transformer/utils.go +++ b/pkg/transformer/utils.go @@ -112,7 +112,7 @@ func ConfigLabels(name string) map[string]string { return map[string]string{Selector: name} } -// ConfigLabels configures label and add Network Information in labels +// ConfigLabelsWithNetwork configures label and add Network Information in labels func ConfigLabelsWithNetwork(name string, net []string) map[string]string { labels := map[string]string{}