CovertEnvToMap coverts env array to map.

ExistTargetVolume checks if the backup.status.backupMethod.targetVolumes exists the target volume which should be restored.

GetActionSetByName gets the ActionSet by name.

GetBackupMethodsFromBackupPolicy get backup methods from backup policy if backup policy is specified, search the backup policy with the name if backup policy is not specified, search the default backup policy if method's snapshotVolumes is true, use the method as the default backup method.

GetBackupTargets gets the backup targets by 'backupMethod' and 'backupPolicy'.

GetDPDBPortEnv get the EnvVar which consists of the port number of targetPod.

GetFirstIndexRunningPod gets the first running pod with index.

GetKubeVersion get the version of Kubernetes and return the gitVersion.

IsJobFinished if the job is completed or failed, return true.

IsVolumeSnapshotEnabled checks if the CSI supports the volume snapshot.

MergeEnv merges the targetEnv to original env.

PrependSpaces prepends spaces to each line of the content.

VolumeSnapshotEnabled checks if the volumes support snapshot.

CompatClient is compatible with VolumeSnapshot v1 and v1beta1, and CronJob v1 and v1beta1.

PeriodicalEnqueueSource is an implementation of interface sigs.k8s.io/controller-runtime/pkg/source/Source It reads the specific resources from cache and enqueue them into the queue to trigger the reconcile procedure periodically.