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

fix synv endpoints

Browse source 
Signed-off-by: zvlb <vl.zemtsov@gmail.com>
This commit is contained in:
zvlb 2024-02-29 17:52:05 +02:00
parent 654a2bb71a
commit 2e9d625214
2 changed files with 15 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
internal/ingress/controller/controller.go
View file

@ -254,7 +254,7 @@ func (n *NGINXController) syncIngress(interface{}) error {
rc := utilingress.GetRemovedCertificateSerialNumbers(n.runningConfig, pcfg) rc := utilingress.GetRemovedCertificateSerialNumbers(n.runningConfig, pcfg)
n.metricCollector.RemoveMetrics(ri, re, rc) n.metricCollector.RemoveMetrics(ri, re, rc)
n.runningConfig.UpdateWithoutEndpoints(pcfg) n.runningConfig = pcfg
return nil return nil
} }
@ -267,11 +267,12 @@ func (n *NGINXController) syncEndpoints(interface{}) error {
return nil return nil
} }
TCPEndpoints := n.getStreamServices(n.cfg.TCPConfigMapName, apiv1.ProtocolTCP) ings := n.store.ListIngresses()
UDPEndpoints := n.getStreamServices(n.cfg.UDPConfigMapName, apiv1.ProtocolUDP)
if ingress.CompareL4Service(n.runningConfig.TCPEndpoints, TCPEndpoints) && ingress.CompareL4Service(n.runningConfig.UDPEndpoints, UDPEndpoints) { _, _, pcfg := n.getConfiguration(ings)
klog.V(3).Infof("No Endpoints change detected, skipping Endpoints reload")
if n.runningConfig.Equal(pcfg) {
klog.V(3).Infof("No configuration change detected, skipping backend reload")
return nil return nil
} }
@ -284,7 +285,7 @@ func (n *NGINXController) syncEndpoints(interface{}) error {
retriesRemaining := retry.Steps retriesRemaining := retry.Steps
err := wait.ExponentialBackoff(retry, func() (bool, error) { err := wait.ExponentialBackoff(retry, func() (bool, error) {
err := updateStreamConfiguration(TCPEndpoints, UDPEndpoints) err := n.configureDynamically(pcfg)
if err == nil { if err == nil {
klog.V(2).Infof("Endpoints reconfiguration succeeded.") klog.V(2).Infof("Endpoints reconfiguration succeeded.")
return true, nil return true, nil
@ -302,7 +303,7 @@ func (n *NGINXController) syncEndpoints(interface{}) error {
return err return err
} }
n.runningConfig.UpdateEndpoints(TCPEndpoints, UDPEndpoints) n.runningConfig = pcfg
return nil return nil
} }

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

@ -828,13 +828,13 @@ func (n *NGINXController) configureDynamically(pcfg *ingress.Configuration) erro
} }
} }
// streamConfigurationChanged := !reflect.DeepEqual(n.runningConfig.TCPEndpoints, pcfg.TCPEndpoints) || !reflect.DeepEqual(n.runningConfig.UDPEndpoints, pcfg.UDPEndpoints) streamConfigurationChanged := !reflect.DeepEqual(n.runningConfig.TCPEndpoints, pcfg.TCPEndpoints) || !reflect.DeepEqual(n.runningConfig.UDPEndpoints, pcfg.UDPEndpoints)
// if streamConfigurationChanged { if streamConfigurationChanged {
// err := updateStreamConfiguration(pcfg.TCPEndpoints, pcfg.UDPEndpoints) err := updateStreamConfiguration(pcfg.TCPEndpoints, pcfg.UDPEndpoints)
// if err != nil { if err != nil {
// return err return err
// } }
// } }
serversChanged := !reflect.DeepEqual(n.runningConfig.Servers, pcfg.Servers) serversChanged := !reflect.DeepEqual(n.runningConfig.Servers, pcfg.Servers)
if serversChanged { if serversChanged {