backup

Documentation

Index

• func AgentContainer(cr *api.PerconaServerMongoDB, replsetName string, replsetSize int32) (corev1.Container, error)
• func BackupCronJob(backup *api.BackupTaskSpec, crName, namespace string, ...) *batchv1b.CronJob
• func HasActiveJobs(cl client.Client, cluster, namespace string, current Job) (bool, error)
• func NewBackupCronJobLabels(crName string) map[string]string
• type Job
• type JobType
• type PBM
  • func NewPBM(c client.Client, cluster *api.PerconaServerMongoDB) (*PBM, error)
  • func (b *PBM) Close() error
  • func (b *PBM) SetConfig(stg api.BackupStorageSpec) error

Functions

func AgentContainer

func AgentContainer(cr *api.PerconaServerMongoDB, replsetName string, replsetSize int32) (corev1.Container, error)

AgentContainer creates the container object for a backup agent

func BackupCronJob

func BackupCronJob(backup *api.BackupTaskSpec, crName, namespace string, backupSpec api.BackupSpec, imagePullSecrets []corev1.LocalObjectReference) *batchv1b.CronJob

func HasActiveJobs

func HasActiveJobs(cl client.Client, cluster, namespace string, current Job) (bool, error)

HasActiveJobs returns true if there are running backups or restores in given cluster and namestpace

func NewBackupCronJobLabels

func NewBackupCronJobLabels(crName string) map[string]string

Types

type Job

type Job struct {
	Name string
	Type JobType
}

type JobType

type JobType int

const (
	TypeBackup JobType = iota
	TypeRestore
)

type PBM

type PBM struct {
	C *pbm.PBM
	// contains filtered or unexported fields
}

func NewPBM

func NewPBM(c client.Client, cluster *api.PerconaServerMongoDB) (*PBM, error)

NewPBM creates a new connection to PBM. It should be closed after the last use with.

func (*PBM) Close

func (b *PBM) Close() error

Close close the PBM connection

func (*PBM) SetConfig

func (b *PBM) SetConfig(stg api.BackupStorageSpec) error

SetConfig sets the pbm config with storage defined in the cluster CR by given storageName