forked from LaconicNetwork/kompose
Merge pull request #967 from hangyan/fix-golint-warnings
Fix golint warnings
This commit is contained in:
commit
fc9e3bc09c
@ -47,8 +47,10 @@ const (
|
|||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
// ProviderKubernetes is provider kubernetes
|
||||||
ProviderKubernetes = "kubernetes"
|
ProviderKubernetes = "kubernetes"
|
||||||
ProviderOpenshift = "openshift"
|
// ProviderOpenshift is provider openshift
|
||||||
|
ProviderOpenshift = "openshift"
|
||||||
// DefaultProvider - provider that will be used if there is no provider was explicitly set
|
// DefaultProvider - provider that will be used if there is no provider was explicitly set
|
||||||
DefaultProvider = ProviderKubernetes
|
DefaultProvider = ProviderKubernetes
|
||||||
)
|
)
|
||||||
|
|||||||
@ -294,7 +294,7 @@ func libComposeToKomposeMapping(composeObject *project.Project) (kobject.Kompose
|
|||||||
|
|
||||||
// This function will retrieve volumes for each service, as well as it will parse volume information and store it in Volumes struct
|
// This function will retrieve volumes for each service, as well as it will parse volume information and store it in Volumes struct
|
||||||
func handleVolume(komposeObject *kobject.KomposeObject) {
|
func handleVolume(komposeObject *kobject.KomposeObject) {
|
||||||
for name, _ := range komposeObject.ServiceConfigs {
|
for name := range komposeObject.ServiceConfigs {
|
||||||
// retrieve volumes of service
|
// retrieve volumes of service
|
||||||
vols, err := retrieveVolume(name, *komposeObject)
|
vols, err := retrieveVolume(name, *komposeObject)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -379,6 +379,7 @@ func checkVolDependent(dv kobject.Volumes, volume []kobject.Volumes) bool {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ParseVols parse volumes
|
||||||
func ParseVols(volNames []string, svcName string) ([]kobject.Volumes, error) {
|
func ParseVols(volNames []string, svcName string) ([]kobject.Volumes, error) {
|
||||||
var volumes []kobject.Volumes
|
var volumes []kobject.Volumes
|
||||||
var err error
|
var err error
|
||||||
|
|||||||
@ -581,6 +581,7 @@ func DurationStrToSecondsInt(s string) (*int64, error) {
|
|||||||
return &r, nil
|
return &r, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetEnvsFromFile get env vars from env_file
|
||||||
func GetEnvsFromFile(file string, opt kobject.ConvertOptions) (map[string]string, error) {
|
func GetEnvsFromFile(file string, opt kobject.ConvertOptions) (map[string]string, error) {
|
||||||
// Get the correct file context / directory
|
// Get the correct file context / directory
|
||||||
composeDir, err := transformer.GetComposeFileDir(opt.InputFiles)
|
composeDir, err := transformer.GetComposeFileDir(opt.InputFiles)
|
||||||
@ -598,6 +599,7 @@ func GetEnvsFromFile(file string, opt kobject.ConvertOptions) (map[string]string
|
|||||||
return envLoad, nil
|
return envLoad, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// FormatEnvName format env name
|
||||||
func FormatEnvName(name string) string {
|
func FormatEnvName(name string) string {
|
||||||
envName := strings.Trim(name, "./")
|
envName := strings.Trim(name, "./")
|
||||||
envName = strings.Replace(envName, ".", "-", -1)
|
envName = strings.Replace(envName, ".", "-", -1)
|
||||||
|
|||||||
@ -579,7 +579,7 @@ func (k *Kubernetes) ConfigEnvs(name string, service kobject.ServiceConfig, opt
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Add configMapKeyRef to each environment variable
|
// Add configMapKeyRef to each environment variable
|
||||||
for k, _ := range envLoad {
|
for k := range envLoad {
|
||||||
envs = append(envs, api.EnvVar{
|
envs = append(envs, api.EnvVar{
|
||||||
Name: k,
|
Name: k,
|
||||||
ValueFrom: &api.EnvVarSource{
|
ValueFrom: &api.EnvVarSource{
|
||||||
|
|||||||
@ -5,7 +5,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
// getImageTag get tag name from image name
|
// GetImageTag get tag name from image name
|
||||||
// if no tag is specified return 'latest'
|
// if no tag is specified return 'latest'
|
||||||
func GetImageTag(image string) string {
|
func GetImageTag(image string) string {
|
||||||
// format: registry_host:registry_port/repo_name/image_name:image_tag
|
// format: registry_host:registry_port/repo_name/image_name:image_tag
|
||||||
@ -31,7 +31,7 @@ func GetImageTag(image string) string {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// getAbsBuildContext returns build context relative to project root dir
|
// GetAbsBuildContext returns build context relative to project root dir
|
||||||
func GetAbsBuildContext(context string) (string, error) {
|
func GetAbsBuildContext(context string) (string, error) {
|
||||||
cmd := exec.Command("git", "rev-parse", "--show-prefix")
|
cmd := exec.Command("git", "rev-parse", "--show-prefix")
|
||||||
cmd.Dir = context
|
cmd.Dir = context
|
||||||
|
|||||||
@ -224,7 +224,7 @@ func BuildDockerImage(service kobject.ServiceConfig, name string, relativePath s
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Connect to the Docker client
|
// Connect to the Docker client
|
||||||
client, err := docker.DockerClient()
|
client, err := docker.Client()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@ -251,20 +251,19 @@ func PushDockerImage(service kobject.ServiceConfig, serviceName string) error {
|
|||||||
if service.Image == "" {
|
if service.Image == "" {
|
||||||
log.Warnf("No image name has been passed for service %s, skipping pushing to repository", serviceName)
|
log.Warnf("No image name has been passed for service %s, skipping pushing to repository", serviceName)
|
||||||
return nil
|
return nil
|
||||||
} else {
|
}
|
||||||
|
|
||||||
// Connect to the Docker client
|
// Connect to the Docker client
|
||||||
client, err := docker.DockerClient()
|
client, err := docker.Client()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
push := docker.Push{Client: *client}
|
push := docker.Push{Client: *client}
|
||||||
err = push.PushImage(service.Image)
|
err = push.PushImage(service.Image)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
@ -21,8 +21,8 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
)
|
)
|
||||||
|
|
||||||
// DockerClient connects to Docker client on host
|
// Client connects to Docker client on host
|
||||||
func DockerClient() (*docker.Client, error) {
|
func Client() (*docker.Client, error) {
|
||||||
|
|
||||||
var (
|
var (
|
||||||
err error
|
err error
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user