backup

Nov 12, 2024

Changes in this version

type PBM

+ DeletePITRChunks func(ctx context.Context, until primitive.Timestamp) error

+ GetConfig func(ctx context.Context) (*config.Config, error)

+ GetNSetConfig func(ctx context.Context, k8sclient client.Client, ...) error

Sep 4, 2024

Changes in this version

type PBM

+ ValidateBackup func(ctx context.Context, bcp *psmdbv1.PerconaServerMongoDBBackup, ...) error

May 21, 2024

Changes in this version

+ const KMSKeyID

+ const SSECustomerKey

+ var ErrNoOplogsForPITR = errors.New("there is no oplogs that can cover the date/time or no oplogs at all")

+ func IsPBMNotConfiguredError(err error) bool

+ type BackupMeta = backup.BackupMeta

type PBM

+ PITRChunksCollection func() *mongo.Collection

Oct 9, 2023

Changes in this version

+ type NewPBMFunc func(ctx context.Context, c client.Client, cluster *api.PerconaServerMongoDB) (PBM, error)

type PBM

+ Conn func() *mongo.Client

+ DeleteBackup func(name string, l *pbmLog.Event) error

+ DeleteConfigVar func(key string) error

+ GetBackupMeta func(name string) (*pbm.BackupMeta, error)

+ GetConfigVar func(key string) (any, error)

+ GetRestoreMeta func(name string) (*pbm.RestoreMeta, error)

+ GetStorage func(l *pbmLog.Event) (storage.Storage, error)

+ Logger func() *pbmLog.Logger

+ Node func() (string, error)

+ PITRGetChunksSlice func(rs string, from, to primitive.Timestamp) ([]pbm.OplogChunk, error)

+ ResyncStorage func(l *pbmLog.Event) error

+ SendCmd func(cmd pbm.Cmd) error

+ SetConfigVar func(key, val string) error

Mar 8, 2023

Changes in this version

+ func GetPBMConfig(ctx context.Context, k8sclient client.Client, ...) (pbm.Config, error)

+ func GetPriorities(ctx context.Context, k8sclient client.Client, ...) (map[string]float64, error)

Sep 14, 2022

Changes in this version

+ const AWSAccessKeySecretKey

+ const AWSSecretAccessKeySecretKey

+ const AzureStorageAccountKeySecretKey

+ const AzureStorageAccountNameSecretKey

+ func BackupFromTask(cr *api.PerconaServerMongoDB, task *api.BackupTaskSpec) (*api.PerconaServerMongoDBBackup, error)

Sep 29, 2021

Changes in this version

type PBM

+ func (b *PBM) GetPriorities(k8sclient client.Client, cluster *api.PerconaServerMongoDB) (map[string]float64, error)

May 4, 2021

Changes in this version

+ func IsPITRLock(l pbm.LockHeader) bool

+ func NotPITRLock(l pbm.LockHeader) bool

type Job

+ func NewBackupJob(name string) Job

+ func NewRestoreJob(cr *api.PerconaServerMongoDBRestore) Job

type JobType

+ const TypePITRestore

+ type LockHeaderPredicate func(pbm.LockHeader) bool

+ func NotJobLock(j Job) LockHeaderPredicate

type PBM

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

Mar 27, 2020

Changes in this version

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

+ type Job struct

+ Name string

+ Type JobType

+ type JobType int

+ const TypeBackup

+ const TypeRestore

+ type PBM struct

+ C *pbm.PBM

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

+ func (b *PBM) Close() error

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

Sep 20, 2019

Changes in this version

+ func NewBackupCronJobLabels(crName string) map[string]string

Jun 26, 2019

Changes in this version

+ func GetCoordinatorSuffix() string

Mar 18, 2019

Changes in this version

+ func AgentContainer(cr *api.PerconaServerMongoDB, sv *version.ServerVersion) corev1.Container

+ func AgentStoragesConfigSecret(cr *api.PerconaServerMongoDB, cl client.Client) (*corev1.Secret, error)

+ func AgentVolume(crName string) corev1.Volume

+ func BackupCronJob(backup *api.BackupTaskSpec, crName, namespace, image string, ...) *batchv1b.CronJob

+ func CoordinatorService(crName, namespace string) *corev1.Service

+ func CoordinatorStatefulSet(cr *api.PerconaServerMongoDB) *appsv1.StatefulSet

+ func CoordinatorStatefulSetSpec(cr *api.PerconaServerMongoDB, spec *api.BackupCoordinatorSpec, ...) appsv1.StatefulSetSpec