Merge pull request #1247 from gtardif/revert_name_prefix

Revert "Prefix kube resource with compose project name "
This commit is contained in:
Guillaume Tardif 2021-02-05 09:51:11 +01:00 committed by GitHub
commit f433fb89d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 15 additions and 24 deletions

View File

@ -45,7 +45,7 @@ func MapToKubernetesObjects(project *types.Project) (map[string]runtime.Object,
for _, service := range project.Services {
svcObject := mapToService(project, service)
if svcObject != nil {
objects[fmt.Sprintf("%s-service.yaml", getProjectServiceName(project, service))] = svcObject
objects[fmt.Sprintf("%s-service.yaml", service.Name)] = svcObject
} else {
log.Println("Missing port mapping from service config.")
}
@ -55,13 +55,13 @@ func MapToKubernetesObjects(project *types.Project) (map[string]runtime.Object,
if err != nil {
return nil, err
}
objects[fmt.Sprintf("%s-daemonset.yaml", getProjectServiceName(project, service))] = daemonset
objects[fmt.Sprintf("%s-daemonset.yaml", service.Name)] = daemonset
} else {
deployment, err := mapToDeployment(project, service)
if err != nil {
return nil, err
}
objects[fmt.Sprintf("%s-deployment.yaml", getProjectServiceName(project, service))] = deployment
objects[fmt.Sprintf("%s-deployment.yaml", service.Name)] = deployment
}
for _, vol := range service.Volumes {
if vol.Type == "volume" {
@ -98,7 +98,7 @@ func mapToService(project *types.Project, service types.ServiceConfig) *core.Ser
APIVersion: "v1",
},
ObjectMeta: meta.ObjectMeta{
Name: getProjectServiceName(project, service),
Name: service.Name,
},
Spec: core.ServiceSpec{
ClusterIP: clusterIP,
@ -126,7 +126,7 @@ func mapToDeployment(project *types.Project, service types.ServiceConfig) (*apps
APIVersion: "apps/v1",
},
ObjectMeta: meta.ObjectMeta{
Name: getProjectServiceName(project, service),
Name: service.Name,
Labels: labels,
},
Spec: apps.DeploymentSpec{
@ -138,10 +138,6 @@ func mapToDeployment(project *types.Project, service types.ServiceConfig) (*apps
}, nil
}
func getProjectServiceName(project *types.Project, service types.ServiceConfig) string {
return fmt.Sprintf("%s-%s", project.Name, service.Name)
}
func selectorLabels(projectName string, serviceName string) map[string]string {
return map[string]string{
compose.ProjectTag: projectName,
@ -158,7 +154,7 @@ func mapToDaemonset(project *types.Project, service types.ServiceConfig) (*apps.
return &apps.DaemonSet{
ObjectMeta: meta.ObjectMeta{
Name: getProjectServiceName(project, service),
Name: service.Name,
Labels: labels,
},
Spec: apps.DaemonSetSpec{

View File

@ -29,7 +29,7 @@ import (
)
func TestServiceWithExposedPort(t *testing.T) {
model, err := loadYAML("myproject", `
model, err := loadYAML(`
services:
nginx:
image: nginx
@ -45,10 +45,10 @@ services:
APIVersion: "v1",
},
ObjectMeta: meta.ObjectMeta{
Name: "myproject-nginx",
Name: "nginx",
},
Spec: core.ServiceSpec{
Selector: map[string]string{"com.docker.compose.service": "nginx", "com.docker.compose.project": "myproject"},
Selector: map[string]string{"com.docker.compose.service": "nginx", "com.docker.compose.project": ""},
Ports: []core.ServicePort{
{
Name: "80-tcp",
@ -62,7 +62,7 @@ services:
}
func TestServiceWithoutExposedPort(t *testing.T) {
model, err := loadYAML("myproject", `
model, err := loadYAML(`
services:
nginx:
image: nginx
@ -76,10 +76,10 @@ services:
APIVersion: "v1",
},
ObjectMeta: meta.ObjectMeta{
Name: "myproject-nginx",
Name: "nginx",
},
Spec: core.ServiceSpec{
Selector: map[string]string{"com.docker.compose.service": "nginx", "com.docker.compose.project": "myproject"},
Selector: map[string]string{"com.docker.compose.service": "nginx", "com.docker.compose.project": ""},
ClusterIP: "None",
Ports: []core.ServicePort{},
Type: core.ServiceTypeClusterIP,

View File

@ -31,7 +31,7 @@ import (
"k8s.io/apimachinery/pkg/api/resource"
)
func loadYAML(projectName string, yaml string) (*types.Project, error) {
func loadYAML(yaml string) (*types.Project, error) {
dict, err := loader.ParseYAML([]byte(yaml))
if err != nil {
return nil, err
@ -51,12 +51,7 @@ func loadYAML(projectName string, yaml string) (*types.Project, error) {
ConfigFiles: configs,
Environment: nil,
}
project, err := loader.Load(config)
if err != nil {
return nil, err
}
project.Name = projectName
return project, nil
return loader.Load(config)
}
func podTemplate(t *testing.T, yaml string) apiv1.PodTemplateSpec {
@ -66,7 +61,7 @@ func podTemplate(t *testing.T, yaml string) apiv1.PodTemplateSpec {
}
func podTemplateWithError(yaml string) (apiv1.PodTemplateSpec, error) {
model, err := loadYAML("myproject", yaml)
model, err := loadYAML(yaml)
if err != nil {
return apiv1.PodTemplateSpec{}, err
}