diff --git a/pkg/ingress/ingress.go b/pkg/ingress/ingress.go index 36be0f4a..386319f3 100644 --- a/pkg/ingress/ingress.go +++ b/pkg/ingress/ingress.go @@ -129,11 +129,10 @@ func (i *Ingress) handlePath(k store.K8s, h haproxy.HAProxy, host string, path * return } // Endpoints - service := svc.GetResource() var endpointsReload bool - if _, ok := k.ServiceProcessed[service.Namespace+"/"+service.Name]; !ok { + if _, ok := k.BackendProcessed[backendName]; !ok { endpointsReload = svc.HandleHAProxySrvs(k, h) - k.ServiceProcessed[service.Namespace+"/"+service.Name] = struct{}{} + k.BackendProcessed[backendName] = struct{}{} } return backendReload || endpointsReload || routeReload, err } diff --git a/pkg/store/store.go b/pkg/store/store.go index 97ce1e85..e5757adb 100644 --- a/pkg/store/store.go +++ b/pkg/store/store.go @@ -29,7 +29,7 @@ type K8s struct { ConfigMaps ConfigMaps PublishServiceAddresses []string SecretsProcessed map[string]struct{} - ServiceProcessed map[string]struct{} + BackendProcessed map[string]struct{} UpdateStatusFunc func(ingresses []*Ingress, publishServiceAddresses []string) } @@ -69,7 +69,7 @@ func NewK8sStore(args utils.OSArgs) K8s { }, }, SecretsProcessed: map[string]struct{}{}, - ServiceProcessed: map[string]struct{}{}, + BackendProcessed: map[string]struct{}{}, } for _, namespace := range args.NamespaceWhitelist { store.NamespacesAccess.Whitelist[namespace] = struct{}{} @@ -134,7 +134,7 @@ func (k *K8s) Clean() { } } k.SecretsProcessed = map[string]struct{}{} - k.ServiceProcessed = map[string]struct{}{} + k.BackendProcessed = map[string]struct{}{} } // GetNamespace returns Namespace. Creates one if not existing