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 *api.PerconaServerMongoDB, current Job, ...) (bool, error)
• func IsPITRLock(l pbm.LockHeader) bool
• func NewBackupCronJobLabels(crName string) map[string]string
• func NotPITRLock(l pbm.LockHeader) bool
• type Job
  • func NewBackupJob(name string) Job
  • func NewRestoreJob(cr *api.PerconaServerMongoDBRestore) Job
• type JobType
• type LockHeaderPredicate
  • func NotJobLock(j Job) LockHeaderPredicate
• type PBM
  • func NewPBM(c client.Client, cluster *api.PerconaServerMongoDB) (*PBM, error)
  • func (b *PBM) Close() error
  • func (b *PBM) GetLastPITRChunk() (*pbm.PITRChunk, error)
  • func (b *PBM) GetLatestTimelinePITR() (pbm.Timeline, error)
  • func (b *PBM) GetPITRChunkContains(unixTS int64) (*pbm.PITRChunk, error)
  • func (b *PBM) GetTimelinesPITR() ([]pbm.Timeline, error)
  • func (b *PBM) HasLocks(predicates ...LockHeaderPredicate) (bool, error)
  • func (b *PBM) SetConfig(stg api.BackupStorageSpec, pitr api.PITRSpec) 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 *api.PerconaServerMongoDB, current Job, allowLock ...LockHeaderPredicate) (bool, error)

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

func IsPITRLock

func IsPITRLock(l pbm.LockHeader) bool

func NewBackupCronJobLabels

func NewBackupCronJobLabels(crName string) map[string]string

func NotPITRLock

func NotPITRLock(l pbm.LockHeader) bool

Types

type Job

type Job struct {
	Name string
	Type JobType
}

func NewBackupJob

func NewBackupJob(name string) Job

func NewRestoreJob

func NewRestoreJob(cr *api.PerconaServerMongoDBRestore) Job

type JobType

type JobType int

const (
	TypeBackup JobType = iota
	TypeRestore
	TypePITRestore
)

type LockHeaderPredicate

type LockHeaderPredicate func(pbm.LockHeader) bool

func NotJobLock

func NotJobLock(j Job) LockHeaderPredicate

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) GetLastPITRChunk

func (b *PBM) GetLastPITRChunk() (*pbm.PITRChunk, error)

func (*PBM) GetLatestTimelinePITR

func (b *PBM) GetLatestTimelinePITR() (pbm.Timeline, error)

func (*PBM) GetPITRChunkContains

func (b *PBM) GetPITRChunkContains(unixTS int64) (*pbm.PITRChunk, error)

func (*PBM) GetTimelinesPITR

func (b *PBM) GetTimelinesPITR() ([]pbm.Timeline, error)

func (*PBM) HasLocks

func (b *PBM) HasLocks(predicates ...LockHeaderPredicate) (bool, error)

func (*PBM) SetConfig

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

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