Handle Headless Services when no ports are present

pkg/transformer/kubernetes/k8sutils.go

@@ -258,7 +258,7 @@ func convertToVersion(obj runtime.Object, groupVersion unversioned.GroupVersion)
 // PortsExist checks if service has ports defined
 func (k *Kubernetes) PortsExist(name string, service kobject.ServiceConfig) bool {
 	if len(service.Port) == 0 {
-		logrus.Warningf("[%s] Service cannot be created because of missing port.", name)
+		logrus.Warningf("[%s] No ports defined, we will create a Headless service.", name)
 		return false
 	}
 	return true
@@ -282,6 +282,27 @@ func (k *Kubernetes) CreateService(name string, service kobject.ServiceConfig, o
 	return svc
 }
 
+// CreateHeadlessService creates a k8s headless service
+func (k *Kubernetes) CreateHeadlessService(name string, service kobject.ServiceConfig, objects []runtime.Object) *api.Service {
+	svc := k.InitSvc(name, service)
+
+	servicePorts := []api.ServicePort{}
+	// Configure a dummy port: https://github.com/kubernetes/kubernetes/issues/32766.
+	servicePorts = append(servicePorts, api.ServicePort{
+		Name: "headless",
+		Port: 55555,
+	})
+
+	svc.Spec.Ports = servicePorts
+	svc.Spec.ClusterIP = "None"
+
+	// Configure annotations
+	annotations := transformer.ConfigAnnotations(service)
+	svc.ObjectMeta.Annotations = annotations
+
+	return svc
+}
+
 // UpdateKubernetesObjects loads configurations to k8s objects
 func (k *Kubernetes) UpdateKubernetesObjects(name string, service kobject.ServiceConfig, objects *[]runtime.Object) {
 	// Configure the environment variables.

pkg/transformer/kubernetes/kubernetes.go

@@ -477,6 +477,9 @@ func (k *Kubernetes) Transform(komposeObject kobject.KomposeObject, opt kobject.
 				if service.ExposeService != "" {
 					objects = append(objects, k.initIngress(name, service, svc.Spec.Ports[0].Port))
 				}
+			} else {
+				svc := k.CreateHeadlessService(name, service, objects)
+				objects = append(objects, svc)
 			}
 		}