Add SharderConfig.controller.sharder.concurrentMoves config field

Author: timebertt

pkg/apis/config/v1alpha1/defaults.go

@@ -95,6 +95,9 @@ func SetDefaults_SharderController(obj *SharderController) {
 	if obj.SyncPeriod == nil {
 		obj.SyncPeriod = &metav1.Duration{Duration: 5 * time.Minute}
 	}
+	if obj.ConcurrentMoves == nil {
+		obj.ConcurrentMoves = ptr.To[int32](100)
+	}
 }
 
 func SetDefaults_Webhook(obj *Webhook) {

pkg/apis/config/v1alpha1/defaults_test.go

@@ -91,7 +91,8 @@ var _ = Describe("SharderConfig defaulting", func() {
 
 			Expect(obj.Controller).To(Equal(Controller{
 				Sharder: &SharderController{
-					SyncPeriod: &metav1.Duration{Duration: 5 * time.Minute},
+					SyncPeriod:      &metav1.Duration{Duration: 5 * time.Minute},
+					ConcurrentMoves: ptr.To[int32](100),
 				},
 			}))
 		})

pkg/apis/config/v1alpha1/types.go

@@ -83,10 +83,15 @@ type Controller struct {
 
 // SharderController configures the sharder controller.
 type SharderController struct {
-	// SyncPeriod configures how often a periodic resync of all object assignments in a ring in performed.
+	// SyncPeriod configures how often a periodic resync of all object assignments in a ring is performed.
 	// Defaults to 5m
 	// +optional
 	SyncPeriod *metav1.Duration `json:"syncPeriod,omitempty"`
+	// ConcurrentMoves configures how many objects of the same ControllerRing are moved (or drained) concurrently at
+	// maximum.
+	// Defaults to 100
+	// +optional
+	ConcurrentMoves *int32 `json:"concurrentMoves,omitempty"`
 }
 
 // Webhook configures webhooks and the webhook server.