cmd/k8s-operator: remove early return in ingress matching (#17841)
Fixes #17834 Signed-off-by: Sachin Iyer <siyer@detail.dev>
This commit is contained in:
@@ -1122,7 +1122,7 @@ func serviceHandlerForIngress(cl client.Client, logger *zap.SugaredLogger, ingre
|
|||||||
reqs := make([]reconcile.Request, 0)
|
reqs := make([]reconcile.Request, 0)
|
||||||
for _, ing := range ingList.Items {
|
for _, ing := range ingList.Items {
|
||||||
if ing.Spec.IngressClassName == nil || *ing.Spec.IngressClassName != ingressClassName {
|
if ing.Spec.IngressClassName == nil || *ing.Spec.IngressClassName != ingressClassName {
|
||||||
return nil
|
continue
|
||||||
}
|
}
|
||||||
if hasProxyGroupAnnotation(&ing) {
|
if hasProxyGroupAnnotation(&ing) {
|
||||||
// We don't want to reconcile backend Services for Ingresses for ProxyGroups.
|
// We don't want to reconcile backend Services for Ingresses for ProxyGroups.
|
||||||
|
|||||||
@@ -1698,6 +1698,42 @@ func Test_serviceHandlerForIngress(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func Test_serviceHandlerForIngress_multipleIngressClasses(t *testing.T) {
|
||||||
|
fc := fake.NewFakeClient()
|
||||||
|
zl, err := zap.NewDevelopment()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
svc := &corev1.Service{
|
||||||
|
ObjectMeta: metav1.ObjectMeta{Name: "backend", Namespace: "default"},
|
||||||
|
}
|
||||||
|
mustCreate(t, fc, svc)
|
||||||
|
|
||||||
|
mustCreate(t, fc, &networkingv1.Ingress{
|
||||||
|
ObjectMeta: metav1.ObjectMeta{Name: "nginx-ing", Namespace: "default"},
|
||||||
|
Spec: networkingv1.IngressSpec{
|
||||||
|
IngressClassName: ptr.To("nginx"),
|
||||||
|
DefaultBackend: &networkingv1.IngressBackend{Service: &networkingv1.IngressServiceBackend{Name: "backend"}},
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
mustCreate(t, fc, &networkingv1.Ingress{
|
||||||
|
ObjectMeta: metav1.ObjectMeta{Name: "ts-ing", Namespace: "default"},
|
||||||
|
Spec: networkingv1.IngressSpec{
|
||||||
|
IngressClassName: ptr.To("tailscale"),
|
||||||
|
DefaultBackend: &networkingv1.IngressBackend{Service: &networkingv1.IngressServiceBackend{Name: "backend"}},
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
got := serviceHandlerForIngress(fc, zl.Sugar(), "tailscale")(context.Background(), svc)
|
||||||
|
want := []reconcile.Request{{NamespacedName: types.NamespacedName{Namespace: "default", Name: "ts-ing"}}}
|
||||||
|
|
||||||
|
if diff := cmp.Diff(got, want); diff != "" {
|
||||||
|
t.Fatalf("unexpected reconcile requests (-got +want):\n%s", diff)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func Test_clusterDomainFromResolverConf(t *testing.T) {
|
func Test_clusterDomainFromResolverConf(t *testing.T) {
|
||||||
zl, err := zap.NewDevelopment()
|
zl, err := zap.NewDevelopment()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user