updated status policy

nginx · Jul 20, 2021 · dfad485 · dfad485
1 parent 3f4ff1f
commit dfad485
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/internal/k8s/controller.go b/internal/k8s/controller.go
@@ -298,6 +298,7 @@ func NewLoadBalancerController(input NewLoadBalancerControllerInput) *LoadBalanc
 		policyLister:             lbc.policyLister,
 		keyFunc:                  keyFunc,
 		confClient:               input.ConfClient,
+		hasCorrectIngressClass:   lbc.HasCorrectIngressClass,
 	}
 
 	lbc.configuration = NewConfiguration(

diff --git a/internal/k8s/status.go b/internal/k8s/status.go
@@ -44,6 +44,7 @@ type statusUpdater struct {
 	transportServerLister    cache.Store
 	policyLister             cache.Store
 	confClient               k8s_nginx.Interface
+	hasCorrectIngressClass   func(interface{}) bool
 }
 
 func (su *statusUpdater) UpdateExternalEndpointsForResources(resource []Resource) error {
@@ -638,6 +639,11 @@ func (su *statusUpdater) UpdatePolicyStatus(pol *v1.Policy, state string, reason
 		return nil
 	}
 
+	if !su.hasCorrectIngressClass(polLatest) {
+		glog.V(3).Infof("ignoring policy with incorrect ingress class")
+		return nil
+	}
+
 	polCopy := polLatest.(*v1.Policy)
 
 	if !hasPolicyStatusChanged(polCopy, state, reason, message) {