Skip to content

Commit b0a10b5

Browse files
committed
debug ci
1 parent 49c3b09 commit b0a10b5

File tree

2 files changed

+14
-14
lines changed

2 files changed

+14
-14
lines changed

internal/controller/indexer/indexer.go

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -57,10 +57,13 @@ func SetupIndexer(mgr ctrl.Manager) error {
5757

5858
// Gateway API indexers - conditional setup based on API availability
5959
for resource, setup := range map[client.Object]func(ctrl.Manager) error{
60-
&gatewayv1.Gateway{}: setupGatewayIndexer,
61-
&gatewayv1.HTTPRoute{}: setupHTTPRouteIndexer,
62-
&gatewayv1.GatewayClass{}: setupGatewayClassIndexer,
63-
&v1alpha1.Consumer{}: setupConsumerIndexer,
60+
&gatewayv1.Gateway{}: setupGatewayIndexer,
61+
&gatewayv1.HTTPRoute{}: setupHTTPRouteIndexer,
62+
&gatewayv1.GatewayClass{}: setupGatewayClassIndexer,
63+
&v1alpha1.Consumer{}: setupConsumerIndexer,
64+
&networkingv1.Ingress{}: setupIngressIndexer,
65+
&networkingv1.IngressClass{}: setupIngressClassIndexer,
66+
&networkingv1beta1.IngressClass{}: setupIngressClassV1beta1Indexer,
6467
} {
6568
if utils.HasAPIResource(mgr, resource) {
6669
if err := setup(mgr); err != nil {
@@ -82,9 +85,7 @@ func SetupIndexer(mgr ctrl.Manager) error {
8285

8386
// Core Kubernetes and APISIX indexers - always setup these
8487
for _, setup := range []func(ctrl.Manager) error{
85-
setupIngressIndexer,
8688
setupBackendTrafficPolicyIndexer,
87-
setupIngressClassIndexer,
8889
setupGatewayProxyIndexer,
8990
setupApisixRouteIndexer,
9091
setupApisixPluginConfigIndexer,

internal/manager/controllers.go

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -105,14 +105,7 @@ func setupControllers(ctx context.Context, mgr manager.Manager, pro provider.Pro
105105
var controllers []Controller
106106

107107
icgvk := types.GvkOf(&v1.IngressClass{})
108-
if utils.HasAPIResource(mgr, &v1.IngressClass{}) {
109-
controllers = append(controllers, &controller.IngressClassReconciler{
110-
Client: mgr.GetClient(),
111-
Scheme: mgr.GetScheme(),
112-
Log: ctrl.LoggerFrom(ctx).WithName("controllers").WithName("IngressClass"),
113-
Provider: pro,
114-
})
115-
} else {
108+
if !utils.HasAPIResource(mgr, &v1.IngressClass{}) {
116109
setupLog.Info("IngressClass v1 not found, falling back to IngressClass v1beta1")
117110
icgvk = types.GvkOf(&v1beta1.IngressClass{})
118111
controllers = append(controllers, &controller.IngressClassV1beta1Reconciler{
@@ -162,6 +155,12 @@ func setupControllers(ctx context.Context, mgr manager.Manager, pro provider.Pro
162155
Updater: updater,
163156
Readier: readier,
164157
},
158+
&v1.IngressClass{}: &controller.IngressClassReconciler{
159+
Client: mgr.GetClient(),
160+
Scheme: mgr.GetScheme(),
161+
Log: ctrl.LoggerFrom(ctx).WithName("controllers").WithName("IngressClass"),
162+
Provider: pro,
163+
},
165164
} {
166165
if utils.HasAPIResource(mgr, resource) {
167166
controllers = append(controllers, controller)

0 commit comments

Comments
 (0)