K8SPSMDB-965 update batch/v1beta1 to batch/v1 (#1296)

Author: hors

pkg/controller/perconaservermongodb/backup.go

@@ -11,7 +11,7 @@ import (
 	"github.com/robfig/cron/v3"
 	"go.mongodb.org/mongo-driver/mongo"
 	"go.mongodb.org/mongo-driver/x/bsonx/bsoncore"
-	batchv1beta1 "k8s.io/api/batch/v1beta1"
+	batchv1 "k8s.io/api/batch/v1"
 	corev1 "k8s.io/api/core/v1"
 	k8sErrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/labels"
@@ -101,7 +101,7 @@ func (r *ReconcilePerconaServerMongoDB) deleteOldBackupTasks(ctx context.Context
 
 	if cr.CompareVersion("1.13.0") < 0 {
 		ls := backup.NewBackupCronJobLabels(cr.Name, cr.Spec.Backup.Labels)
-		tasksList := &batchv1beta1.CronJobList{}
+		tasksList := &batchv1.CronJobList{}
 		err := r.client.List(ctx,
 			tasksList,
 			&client.ListOptions{

pkg/psmdb/backup/job.go

@@ -6,7 +6,6 @@ import (
 	"time"
 
 	batchv1 "k8s.io/api/batch/v1"
-	batchv1beta1 "k8s.io/api/batch/v1beta1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
@@ -15,11 +14,11 @@ import (
 	"github.com/pkg/errors"
 )
 
-func BackupCronJob(cr *api.PerconaServerMongoDB, task *api.BackupTaskSpec) (batchv1beta1.CronJob, error) {
+func BackupCronJob(cr *api.PerconaServerMongoDB, task *api.BackupTaskSpec) (batchv1.CronJob, error) {
 	backupSpec := cr.Spec.Backup
 	containerArgs, err := newBackupCronJobContainerArgs(cr, task)
 	if err != nil {
-		return batchv1beta1.CronJob{}, errors.Wrap(err, "cannot generate container arguments")
+		return batchv1.CronJob{}, errors.Wrap(err, "cannot generate container arguments")
 	}
 
 	backupPod := corev1.PodSpec{
@@ -50,9 +49,9 @@ func BackupCronJob(cr *api.PerconaServerMongoDB, task *api.BackupTaskSpec) (batc
 		RuntimeClassName: backupSpec.RuntimeClassName,
 	}
 
-	return batchv1beta1.CronJob{
+	return batchv1.CronJob{
 		TypeMeta: metav1.TypeMeta{
-			APIVersion: "batch/v1beta1",
+			APIVersion: "batch/v1",
 			Kind:       "CronJob",
 		},
 		ObjectMeta: metav1.ObjectMeta{
@@ -61,10 +60,10 @@ func BackupCronJob(cr *api.PerconaServerMongoDB, task *api.BackupTaskSpec) (batc
 			Labels:      NewBackupCronJobLabels(cr.Name, backupSpec.Labels),
 			Annotations: backupSpec.Annotations,
 		},
-		Spec: batchv1beta1.CronJobSpec{
+		Spec: batchv1.CronJobSpec{
 			Schedule:          task.Schedule,
-			ConcurrencyPolicy: batchv1beta1.ForbidConcurrent,
-			JobTemplate: batchv1beta1.JobTemplateSpec{
+			ConcurrencyPolicy: batchv1.ForbidConcurrent,
+			JobTemplate: batchv1.JobTemplateSpec{
 				ObjectMeta: metav1.ObjectMeta{
 					Labels:      NewBackupCronJobLabels(cr.Name, backupSpec.Labels),
 					Annotations: backupSpec.Annotations,