diff --git a/nginx-controller/controller/controller.go b/nginx-controller/controller/controller.go index d6b90b4409..79a7682201 100644 --- a/nginx-controller/controller/controller.go +++ b/nginx-controller/controller/controller.go @@ -285,6 +285,9 @@ func (lbc *LoadBalancerController) syncEndp(key string) { ings := lbc.getIngressForEndpoints(obj) for _, ing := range ings { + if !isNginxIngress(&ing) { + continue + } ingEx := lbc.createIngress(&ing) glog.V(3).Infof("Updating Endpoints for %v/%v", ing.Name, ing.Namespace) name := ing.Namespace + "-" + ing.Name @@ -353,6 +356,9 @@ func (lbc *LoadBalancerController) syncCfgm(key string) { ings, _ := lbc.ingLister.List() for _, ing := range ings.Items { + if !isNginxIngress(&ing) { + continue + } lbc.ingQueue.enqueue(&ing) } } @@ -385,6 +391,9 @@ func (lbc *LoadBalancerController) enqueueIngressForService(obj interface{}) { svc := obj.(*api.Service) ings := lbc.getIngressesForService(svc) for _, ing := range ings { + if !isNginxIngress(&ing) { + continue + } lbc.ingQueue.enqueue(&ing) } } diff --git a/nginx-plus-controller/controller/controller.go b/nginx-plus-controller/controller/controller.go index 580d0e6178..0f3b1bf0bb 100644 --- a/nginx-plus-controller/controller/controller.go +++ b/nginx-plus-controller/controller/controller.go @@ -284,6 +284,9 @@ func (lbc *LoadBalancerController) syncEndp(key string) { ings := lbc.getIngressForEndpoints(obj) for _, ing := range ings { + if !isNginxIngress(&ing) { + continue + } ingEx := lbc.createIngress(&ing) glog.V(3).Infof("Updating Endpoints for %v/%v", ing.Name, ing.Namespace) name := ing.Namespace + "-" + ing.Name @@ -326,6 +329,9 @@ func (lbc *LoadBalancerController) syncCfgm(key string) { ings, _ := lbc.ingLister.List() for _, ing := range ings.Items { + if !isNginxIngress(&ing) { + continue + } lbc.ingQueue.enqueue(&ing) } } @@ -358,6 +364,9 @@ func (lbc *LoadBalancerController) enqueueIngressForService(obj interface{}) { svc := obj.(*api.Service) ings := lbc.getIngressesForService(svc) for _, ing := range ings { + if !isNginxIngress(&ing) { + continue + } lbc.ingQueue.enqueue(&ing) } }