DevFW-CICD/ingress-nginx-helm
12
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

L4 config - Only send Service.Spec instead of entire Service.

Browse source
This commit is contained in:
Kevin Pullin 2019-01-02 09:32:57 -08:00
parent f0173f0822
commit f005d4c3ec
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
internal/ingress/controller/nginx.go
View file

@ -816,21 +816,31 @@ func configureDynamically(pcfg *ingress.Configuration, port int, isDynamicCertif
streams := make([]ingress.Backend, 0) streams := make([]ingress.Backend, 0)
for _, ep := range pcfg.TCPEndpoints { for _, ep := range pcfg.TCPEndpoints {
var service *apiv1.Service
if ep.Service != nil {
service = &apiv1.Service{Spec: ep.Service.Spec}
}
key := fmt.Sprintf("tcp-%v-%v-%v", ep.Backend.Namespace, ep.Backend.Name, ep.Backend.Port.String()) key := fmt.Sprintf("tcp-%v-%v-%v", ep.Backend.Namespace, ep.Backend.Name, ep.Backend.Port.String())
streams = append(streams, ingress.Backend{ streams = append(streams, ingress.Backend{
Name: key, Name: key,
Endpoints: ep.Endpoints, Endpoints: ep.Endpoints,
Port: intstr.FromInt(ep.Port), Port: intstr.FromInt(ep.Port),
Service: ep.Service, Service: service,
}) })
} }
for _, ep := range pcfg.UDPEndpoints { for _, ep := range pcfg.UDPEndpoints {
var service *apiv1.Service
if ep.Service != nil {
service = &apiv1.Service{Spec: ep.Service.Spec}
}
key := fmt.Sprintf("udp-%v-%v-%v", ep.Backend.Namespace, ep.Backend.Name, ep.Backend.Port.String()) key := fmt.Sprintf("udp-%v-%v-%v", ep.Backend.Namespace, ep.Backend.Name, ep.Backend.Port.String())
streams = append(streams, ingress.Backend{ streams = append(streams, ingress.Backend{
Name: key, Name: key,
Endpoints: ep.Endpoints, Endpoints: ep.Endpoints,
Port: intstr.FromInt(ep.Port), Port: intstr.FromInt(ep.Port),
Service: ep.Service, Service: service,
}) })
} }