backup

Documentation

Index

• Variables
• func CheckPITRErrors(ctx context.Context, cl client.Client, clcmd *clientcmd.Client, ...) error
• func GenName63(cr *api.PerconaXtraDBClusterBackup) string
• func NewPVC(cr *api.PerconaXtraDBClusterBackup) *corev1.PersistentVolumeClaim
• func PVCRestorePod(cr *api.PerconaXtraDBClusterRestore, bcpStorageName, pvcName string, ...) (*corev1.Pod, error)
• func PVCRestoreService(cr *api.PerconaXtraDBClusterRestore) *corev1.Service
• func RestoreJob(cr *api.PerconaXtraDBClusterRestore, bcp *api.PerconaXtraDBClusterBackup, ...) (*batchv1.Job, error)
• func SetStorageAzure(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup) error
• func SetStoragePVC(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup, volName string) error
• func SetStorageS3(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup) error
• func UpdatePITRTimeline(ctx context.Context, cl client.Client, clcmd *clientcmd.Client, ...) error
• type Backup
  • func New(cr *api.PerconaXtraDBCluster) *Backup
  • func (*Backup) Job(cr *api.PerconaXtraDBClusterBackup, cluster *api.PerconaXtraDBCluster) *batchv1.Job
  • func (bcp *Backup) JobSpec(spec api.PXCBackupSpec, cluster *api.PerconaXtraDBCluster, job *batchv1.Job) (batchv1.JobSpec, error)

Variables

var ErrNoBackups = errors.New("No backups found")

Functions

func CheckPITRErrors

func CheckPITRErrors(ctx context.Context, cl client.Client, clcmd *clientcmd.Client, cr *api.PerconaXtraDBCluster) error

func GenName63

func GenName63(cr *api.PerconaXtraDBClusterBackup) string

GenName63 generates legit name for backup resources. k8s sets the `job-name` label for the created by job pod. So we have to be sure that job name won't be longer than 63 symbols. Yet the job name has to have some meaningful name which won't be conflicting with other jobs' names.

func NewPVC

func NewPVC(cr *api.PerconaXtraDBClusterBackup) *corev1.PersistentVolumeClaim

NewPVC returns the list of PersistentVolumeClaims for the backups

func PVCRestorePod

func PVCRestorePod(cr *api.PerconaXtraDBClusterRestore, bcpStorageName, pvcName string, cluster *api.PerconaXtraDBCluster) (*corev1.Pod, error)

func PVCRestoreService

func PVCRestoreService(cr *api.PerconaXtraDBClusterRestore) *corev1.Service

func RestoreJob

func RestoreJob(cr *api.PerconaXtraDBClusterRestore, bcp *api.PerconaXtraDBClusterBackup, cluster *api.PerconaXtraDBCluster, destination api.PXCBackupDestination, pitr bool) (*batchv1.Job, error)

func SetStorageAzure

func SetStorageAzure(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup) error

func SetStoragePVC

func SetStoragePVC(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup, volName string) error

func SetStorageS3

func SetStorageS3(job *batchv1.JobSpec, cr *api.PerconaXtraDBClusterBackup) error

func UpdatePITRTimeline

func UpdatePITRTimeline(ctx context.Context, cl client.Client, clcmd *clientcmd.Client, cr *api.PerconaXtraDBCluster) error

Types

type Backup

type Backup struct {
	// contains filtered or unexported fields
}

func New

func New(cr *api.PerconaXtraDBCluster) *Backup

func (*Backup) Job

func (*Backup) Job(cr *api.PerconaXtraDBClusterBackup, cluster *api.PerconaXtraDBCluster) *batchv1.Job

func (*Backup) JobSpec

func (bcp *Backup) JobSpec(spec api.PXCBackupSpec, cluster *api.PerconaXtraDBCluster, job *batchv1.Job) (batchv1.JobSpec, error)