diff --git a/provider/kubernetes.go b/provider/kubernetes.go index 3f2d1f492..4af905084 100644 --- a/provider/kubernetes.go +++ b/provider/kubernetes.go @@ -9,6 +9,7 @@ import ( "io" "io/ioutil" "os" + "strconv" "strings" "text/template" "time" @@ -200,12 +201,12 @@ func (provider *Kubernetes) loadIngresses(k8sClient k8s.Client) (*types.Configur for _, service := range services { protocol := "http" for _, port := range service.Spec.Ports { - if port.Port == pa.Backend.ServicePort.IntValue() { + if equalPorts(port, pa.Backend.ServicePort) { if port.Port == 443 { protocol = "https" } templateObjects.Backends[r.Host+pa.Path].Servers[string(service.UID)] = types.Server{ - URL: protocol + "://" + service.Spec.ClusterIP + ":" + pa.Backend.ServicePort.String(), + URL: protocol + "://" + service.Spec.ClusterIP + ":" + strconv.Itoa(port.Port), Weight: 1, } break @@ -218,6 +219,16 @@ func (provider *Kubernetes) loadIngresses(k8sClient k8s.Client) (*types.Configur return &templateObjects, nil } +func equalPorts(servicePort k8s.ServicePort, ingressPort k8s.IntOrString) bool { + if servicePort.Port == ingressPort.IntValue() { + return true + } + if servicePort.Name != "" && servicePort.Name == ingressPort.String() { + return true + } + return false +} + func (provider *Kubernetes) getPassHostHeader() bool { if provider.disablePassHostHeaders { return false diff --git a/provider/kubernetes_test.go b/provider/kubernetes_test.go index ccd0818d6..0b9b98d62 100644 --- a/provider/kubernetes_test.go +++ b/provider/kubernetes_test.go @@ -21,7 +21,7 @@ func TestLoadIngresses(t *testing.T) { Path: "/bar", Backend: k8s.IngressBackend{ ServiceName: "service1", - ServicePort: k8s.FromInt(801), + ServicePort: k8s.FromString("http"), }, }, },