Fix Panic on pause and resume cli (#779)

Signed-off-by: souravbiswassanto <[email protected]>
kubedb · Oct 15, 2024 · 1fa678d · 1fa678d
1 parent 6d82a89
commit 1fa678d
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 8 deletions.
diff --git a/pkg/pauser/mariadb.go b/pkg/pauser/mariadb.go
@@ -76,7 +76,7 @@ func (e *MariaDBPauser) Pause(name, namespace string) (bool, error) {
 	}
 
 	pauseAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
-	if e.onlyArchiver || pauseAll {
+	if (e.onlyArchiver || pauseAll) && db.Spec.Archiver != nil {
 		if err := PauseOrResumeMariaDBArchiver(e.kc, true, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/pauser/mongodb.go b/pkg/pauser/mongodb.go
@@ -76,7 +76,7 @@ func (e *MongoDBPauser) Pause(name, namespace string) (bool, error) {
 	}
 
 	pauseAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
-	if e.onlyArchiver || pauseAll {
+	if (e.onlyArchiver || pauseAll) && db.Spec.Archiver != nil {
 		if err := PauseOrResumeMongoDBArchiver(e.kc, true, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/pauser/mysql.go b/pkg/pauser/mysql.go
@@ -75,7 +75,7 @@ func (e *MySQLPauser) Pause(name string, namespace string) (bool, error) {
 		return false, nil
 	}
 	pauseAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
-	if e.onlyArchiver || pauseAll {
+	if (e.onlyArchiver || pauseAll) && db.Spec.Archiver != nil {
 		if err := PauseOrResumeMySQLArchiver(e.kc, true, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/pauser/postgres.go b/pkg/pauser/postgres.go
@@ -77,7 +77,7 @@ func (e *PostgresPauser) Pause(name, namespace string) (bool, error) {
 
 	pauseAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
 
-	if e.onlyArchiver || pauseAll {
+	if (e.onlyArchiver || pauseAll) && db.Spec.Archiver != nil {
 		if err := PauseOrResumePostgresArchiver(e.kc, true, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/resumer/mariadb.go b/pkg/resumer/mariadb.go
@@ -76,7 +76,7 @@ func (e *MariaDBResumer) Resume(name, namespace string) (bool, error) {
 
 	resumeAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
 
-	if e.onlyArchiver || resumeAll {
+	if (e.onlyArchiver || resumeAll) && db.Spec.Archiver != nil {
 		if err := pautil.PauseOrResumeMariaDBArchiver(e.kc, false, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/resumer/mongodb.go b/pkg/resumer/mongodb.go
@@ -77,7 +77,7 @@ func (e *MongoDBResumer) Resume(name, namespace string) (bool, error) {
 	}
 	resumeAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
 
-	if e.onlyArchiver || resumeAll {
+	if (e.onlyArchiver || resumeAll) && db.Spec.Archiver != nil {
 		if err := pautil.PauseOrResumeMongoDBArchiver(e.kc, false, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/resumer/mysql.go b/pkg/resumer/mysql.go
@@ -76,7 +76,7 @@ func (e *MySQLResumer) Resume(name, namespace string) (bool, error) {
 
 	resumeAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
 
-	if e.onlyArchiver || resumeAll {
+	if (e.onlyArchiver || resumeAll) && db.Spec.Archiver != nil {
 		if err := pautil.PauseOrResumeMySQLArchiver(e.kc, false, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}

diff --git a/pkg/resumer/postgres.go b/pkg/resumer/postgres.go
@@ -77,7 +77,7 @@ func (e *PostgresResumer) Resume(name, namespace string) (bool, error) {
 	}
 	resumeAll := !(e.onlyBackup || e.onlyDb || e.onlyArchiver)
 
-	if e.onlyArchiver || resumeAll {
+	if (e.onlyArchiver || resumeAll) && db.Spec.Archiver != nil {
 		if err := pautil.PauseOrResumePostgresArchiver(e.kc, false, db.Spec.Archiver.Ref); err != nil {
 			return false, err
 		}