From fe799d7546247e1a47822827abac90ae42cb98da Mon Sep 17 00:00:00 2001 From: Scott Seago Date: Wed, 13 Aug 2025 14:30:44 -0400 Subject: [PATCH] feat: Add concurrent backups configuration to backup reconciler Co-authored-by: aider (gemini/gemini-2.5-pro) Signed-off-by: Scott Seago --- pkg/cmd/server/server.go | 1 + pkg/controller/backup_controller.go | 3 +++ 2 files changed, 4 insertions(+) diff --git a/pkg/cmd/server/server.go b/pkg/cmd/server/server.go index 83203ca06..fbff1086d 100644 --- a/pkg/cmd/server/server.go +++ b/pkg/cmd/server/server.go @@ -669,6 +669,7 @@ func (s *server) runControllers(defaultVolumeSnapshotLocations map[string]string s.config.MaxConcurrentK8SConnections, s.config.DefaultSnapshotMoveData, s.config.ItemBlockWorkerCount, + s.config.ConcurrentBackups, s.crClient, ).SetupWithManager(s.mgr); err != nil { s.logger.Fatal(err, "unable to create controller", "controller", constant.ControllerBackup) diff --git a/pkg/controller/backup_controller.go b/pkg/controller/backup_controller.go index c9728ea82..22762bff7 100644 --- a/pkg/controller/backup_controller.go +++ b/pkg/controller/backup_controller.go @@ -105,6 +105,7 @@ type backupReconciler struct { defaultSnapshotMoveData bool globalCRClient kbclient.Client itemBlockWorkerCount int + concurrentBackups int workerPool *pkgbackup.ItemBlockWorkerPool } @@ -132,6 +133,7 @@ func NewBackupReconciler( maxConcurrentK8SConnections int, defaultSnapshotMoveData bool, itemBlockWorkerCount int, + concurrentBackups int, globalCRClient kbclient.Client, ) *backupReconciler { b := &backupReconciler{ @@ -159,6 +161,7 @@ func NewBackupReconciler( maxConcurrentK8SConnections: maxConcurrentK8SConnections, defaultSnapshotMoveData: defaultSnapshotMoveData, itemBlockWorkerCount: itemBlockWorkerCount, + concurrentBackups: concurrentBackups, globalCRClient: globalCRClient, workerPool: pkgbackup.StartItemBlockWorkerPool(ctx, itemBlockWorkerCount, logger), }