feat: Add concurrentBackups to backupQueueReconciler

Co-authored-by: aider (gemini/gemini-2.5-pro) <aider@aider.chat>
Signed-off-by: Scott Seago <sseago@redhat.com>
This commit is contained in:
Scott Seago
2025-08-13 14:23:45 -04:00
parent 9dfa108579
commit d91d50f696
3 changed files with 10 additions and 6 deletions

View File

@@ -30,8 +30,9 @@ import (
// backupQueueReconciler reconciles a Backup object
type backupQueueReconciler struct {
client.Client
Scheme *runtime.Scheme
logger logrus.FieldLogger
Scheme *runtime.Scheme
logger logrus.FieldLogger
concurrentBackups int
}
// NewBackupQueueReconciler returns a new backupQueueReconciler
@@ -39,11 +40,13 @@ func NewBackupQueueReconciler(
client client.Client,
scheme *runtime.Scheme,
logger logrus.FieldLogger,
concurrentBackups int,
) *backupQueueReconciler {
return &backupQueueReconciler{
Client: client,
Scheme: scheme,
logger: logger,
Client: client,
Scheme: scheme,
logger: logger,
concurrentBackups: concurrentBackups,
}
}

View File

@@ -47,7 +47,7 @@ func TestBackupQueueReconciler(t *testing.T) {
logger := logrus.New()
log := logger.WithField("controller", "backup-queue-test")
r := NewBackupQueueReconciler(fakeClient, scheme, log)
r := NewBackupQueueReconciler(fakeClient, scheme, log, 1)
req := ctrl.Request{
NamespacedName: types.NamespacedName{
Namespace: "velero",