Function Execute

tests/utils/backups/backup.go:139–204

Execute performs a backup and checks the backup status

(
	ctx context.Context,
	crudClient client.Client,
	scheme *runtime.Scheme,
	namespace,
	backupFile string,
	onlyTargetStandbys bool,
	timeoutSeconds int,
)

// Execute performs a backup and checks the backup status
func Execute(
	ctx context.Context,
	crudClient client.Client,
	scheme *runtime.Scheme,
	namespace,
	backupFile string,
	onlyTargetStandbys bool,
	timeoutSeconds int,
) *apiv1.Backup {
	backupName, err := yaml.GetResourceNameFromYAML(scheme, backupFile)
	gomega.Expect(err).ToNot(gomega.HaveOccurred())
	gomega.Eventually(func() error {
		_, stderr, err := run.Unchecked("kubectl apply -n " + namespace + " -f " + backupFile)
		if err != nil {
			return fmt.Errorf("could not create backup.\nStdErr: %v\nError: %v", stderr, err)
		}
		return nil
	}, 60, objects.PollingTime).Should(gomega.Succeed())
	backupNamespacedName := types.NamespacedName{
		Namespace: namespace,
		Name:      backupName,
	}
	backup := &apiv1.Backup{}
	// Verifying backup status
	gomega.Eventually(func() (apiv1.BackupPhase, error) {
		err = crudClient.Get(ctx, backupNamespacedName, backup)
		return backup.Status.Phase, err
	}, timeoutSeconds).Should(gomega.BeEquivalentTo(apiv1.BackupPhaseCompleted))
	gomega.Eventually(func() (string, error) {
		err = crudClient.Get(ctx, backupNamespacedName, backup)
		if err != nil {
			return "", err
		}
		backupStatus := backup.GetStatus()
		return backupStatus.BeginLSN, err
	}, timeoutSeconds).ShouldNot(gomega.BeEmpty())

	var cluster *apiv1.Cluster
	gomega.Eventually(func() error {
		var err error
		cluster, err = clusterutils.Get(ctx, crudClient, namespace, backup.Spec.Cluster.Name)
		return err
	}, timeoutSeconds).ShouldNot(gomega.HaveOccurred())

	backupStatus := backup.GetStatus()
	if cluster.Spec.Backup != nil {
		backupTarget := cluster.Spec.Backup.Target
		if backup.Spec.Target != "" {
			backupTarget = backup.Spec.Target
		}
		switch backupTarget {
		case apiv1.BackupTargetPrimary, "":
			gomega.Expect(backupStatus.InstanceID.PodName).To(gomega.BeEquivalentTo(cluster.Status.TargetPrimary))
		case apiv1.BackupTargetStandby:
			gomega.Expect(backupStatus.InstanceID.PodName).To(gomega.BeElementOf(cluster.Status.InstanceNames))
			if onlyTargetStandbys {
				gomega.Expect(backupStatus.InstanceID.PodName).NotTo(gomega.Equal(cluster.Status.TargetPrimary))
			}