Use GOMAXPROCS for MaxConcurrentReconciles

Update this to be consistent with our other controllers. I believe this equates to 128, but setting this programmatically is probably the better way to go. Signed-off-by: Blake Devcich <[email protected]>
NearNodeFlash · Nov 27, 2023 · 26bf60d · 26bf60d
1 parent ec0020c
commit 26bf60d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/controller/datamovement_controller.go b/internal/controller/datamovement_controller.go
@@ -31,6 +31,7 @@ import (
 	"path/filepath"
 	"reflect"
 	"regexp"
+	"runtime"
 	"strconv"
 	"strings"
 	"sync"
@@ -736,9 +737,10 @@ func filterByNamespace(namespace string) predicate.Predicate {
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *DataMovementReconciler) SetupWithManager(mgr ctrl.Manager) error {
+	maxReconciles := runtime.GOMAXPROCS(0)
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&nnfv1alpha1.NnfDataMovement{}).
-		WithOptions(controller.Options{MaxConcurrentReconciles: 128}).
+		WithOptions(controller.Options{MaxConcurrentReconciles: maxReconciles}).
 		WithEventFilter(filterByNamespace(r.WatchNamespace)).
 		Complete(r)
 }