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

Add tcp e2e test

Browse source
This commit is contained in:
Manuel Alejandro de Brito Fontes 2018-11-16 17:33:56 -03:00
parent 168f30d1ec
commit 654eceda46
No known key found for this signature in database
GPG key ID: 786136016A8BA02A
4 changed files with 110 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -801,10 +801,10 @@ func configureDynamically(pcfg *ingress.Configuration, port int, isDynamicCertif
}
defer conn.Close()
var streams []*ingress.Backend
streams := make([]ingress.Backend, 0)
for _, ep := range pcfg.TCPEndpoints {
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,
Endpoints: ep.Endpoints,
Port: intstr.FromInt(ep.Port),
@ -812,7 +812,7 @@ func configureDynamically(pcfg *ingress.Configuration, port int, isDynamicCertif
}
for _, ep := range pcfg.UDPEndpoints {
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,
Endpoints: ep.Endpoints,
Port: intstr.FromInt(ep.Port),
@ -828,7 +828,11 @@ func configureDynamically(pcfg *ingress.Configuration, port int, isDynamicCertif
if err != nil {
return err
}
fmt.Fprintf(conn, "\r\n")
_, err = fmt.Fprintf(conn, "\r\n")
if err != nil {
return err
}
defer conn.Close()
if isDynamicCertificatesEnabled {
err = configureCertificates(pcfg, port)