From 1d38d0e1e29050f67b12516fab1fd17415f4530a Mon Sep 17 00:00:00 2001 From: Alexander Yastrebov Date: Mon, 9 May 2022 14:27:40 +0200 Subject: [PATCH] Skip ingress loadbalancer update Signed-off-by: Alexander Yastrebov --- worker.go | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/worker.go b/worker.go index 2fc252ef..0197e7e9 100644 --- a/worker.go +++ b/worker.go @@ -594,6 +594,9 @@ func updateIngress(kubeAdapter *kubernetes.Adapter, lb *loadBalancer, problems * } for _, ingresses := range lb.ingresses { for _, ing := range ingresses { + if skipUpdateIngressLoadBalancer(ing) { + continue + } if err := kubeAdapter.UpdateIngressLoadBalancer(ing, dnsName); err != nil { if err == kubernetes.ErrUpdateNotNeeded { log.Debugf("Update not needed for %s with DNS name %s", ing, dnsName) @@ -625,7 +628,7 @@ func updateDNS(dnsUpdater kubernetes.DNSUpdater, model []*loadBalancer, problems for _, ingresses := range lb.ingresses { for _, ingress := range ingresses { - if ingress.ResourceType != kubernetes.TypeFabricGateway { + if skipUpdateHostnames(ingress) { continue } for _, hostname := range ingress.Hostnames { @@ -646,6 +649,14 @@ func updateDNS(dnsUpdater kubernetes.DNSUpdater, model []*loadBalancer, problems } } +func skipUpdateIngressLoadBalancer(ingress *kubernetes.Ingress) bool { + return ingress.ResourceType == kubernetes.TypeFabricGateway +} + +func skipUpdateHostnames(ingress *kubernetes.Ingress) bool { + return !skipUpdateIngressLoadBalancer(ingress) +} + func deleteStack(awsAdapter *aws.Adapter, lb *loadBalancer, problems *problem.List) { stackName := lb.stack.Name if err := awsAdapter.DeleteStack(lb.stack); err != nil {