Merge pull request #119 from datum-cloud/feat/gatewayconcurrentreconciles

feat: add config for gateway concurrent reconciles

Author: zachsmith1

config/crd/bases/networking.datumapis.com_httpproxies.yaml

@@ -21,6 +21,9 @@ spec:
     - jsonPath: .status.conditions[?(@.type=="Programmed")].status
       name: Programmed
       type: string
+    - jsonPath: .status.conditions[?(@.type=="CertificatesReady")].status
+      name: Certificates
+      type: string
     - jsonPath: .metadata.creationTimestamp
       name: Age
       type: date

internal/config/config.go

@@ -558,6 +558,13 @@ type GatewayConfig struct {
 	//
 	// Defaults to false.
 	EnableDNSIntegration bool `json:"enableDNSIntegration,omitempty"`
+
+	// MaxConcurrentReconciles is the maximum number of concurrent gateway
+	// reconciliations. Higher values allow the controller to process gateways
+	// across multiple projects in parallel.
+	//
+	// +default=5
+	MaxConcurrentReconciles int `json:"maxConcurrentReconciles,omitempty"`
 }
 
 // ShouldDeleteErroredChallenges returns whether the operator should automatically

internal/config/zz_generated.defaults.go

@@ -26,6 +26,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/client/apiutil"
 	"sigs.k8s.io/controller-runtime/pkg/cluster"
+	"sigs.k8s.io/controller-runtime/pkg/controller"
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	"sigs.k8s.io/controller-runtime/pkg/handler"
 	"sigs.k8s.io/controller-runtime/pkg/log"
@@ -1613,7 +1614,11 @@ func (r *GatewayReconciler) SetupWithManager(mgr mcmanager.Manager) error {
 			)
 	}
 
-	return builder.Named("gateway").Complete(r)
+	return builder.
+		WithOptions(controller.TypedOptions[mcreconcile.Request]{
+			MaxConcurrentReconciles: r.Config.Gateway.MaxConcurrentReconciles,
+		}).
+		Named("gateway").Complete(r)
 }
 
 // listGatewaysAttachedByHTTPRoute is a watch predicate which finds all Gateways mentioned