xtrabackup

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteJobName added in v0.3.0 

func DeleteJobName(cr *apiv1.PerconaServerMySQLBackup) string

func DeleteName added in v0.3.0 

func DeleteName(cr *apiv1.PerconaServerMySQLBackup) string

func GetDeleteJob added in v0.3.0 

func GetDeleteJob(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLBackup, conf *BackupConfig) *batchv1.Job

func GetDestination added in v0.12.0 

func GetDestination(
	storage *apiv1.BackupStorageSpec,
	cr *apiv1.PerconaServerMySQLBackup,
	ts time.Time,
) (apiv1.BackupDestination, error)

GetDestination returns the destination for the backup.

func Job 

func Job(
	cluster *apiv1.PerconaServerMySQL,
	cr *apiv1.PerconaServerMySQLBackup,
	destination apiv1.BackupDestination, initImage string,
	storage *apiv1.BackupStorageSpec,
) (*batchv1.Job, error)

func JobName 

func JobName(cr *apiv1.PerconaServerMySQLBackup) string

func JobNamespacedName added in v0.9.0 

func JobNamespacedName(cr *apiv1.PerconaServerMySQLBackup) types.NamespacedName

func Name 

func Name(cr *apiv1.PerconaServerMySQLBackup) string

func PVC 

func PVC(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLBackup, storage *apiv1.BackupStorageSpec) *corev1.PersistentVolumeClaim

func RestoreJob 

func RestoreJob(
	cluster *apiv1.PerconaServerMySQL,
	destination DestinationInfo,
	restore *apiv1.PerconaServerMySQLRestore,
	storage *apiv1.BackupStorageSpec,
	initImage string,
	pvcName string,
) *batchv1.Job

func RestoreJobName 

func RestoreJobName(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLRestore) string

func RestoreName 

func RestoreName(cr *apiv1.PerconaServerMySQLRestore) string

func SetIncrementalLsn added in v1.1.0 

func SetIncrementalLsn(job *batchv1.Job, lsn string) error

func SetSourceNode 

func SetSourceNode(job *batchv1.Job, src string) error

func SetStorageAzure 

func SetStorageAzure(job *batchv1.Job, azure *apiv1.BackupStorageAzureSpec) error

func SetStorageGCS 

func SetStorageGCS(job *batchv1.Job, gcs *apiv1.BackupStorageGCSSpec) error

func SetStoragePVC 

func SetStoragePVC(job *batchv1.Job, pvc *corev1.PersistentVolumeClaim) error

func SetStorageS3 

func SetStorageS3(job *batchv1.Job, s3 *apiv1.BackupStorageS3Spec) error

Types

type BackupConfig added in v0.3.0 

type BackupConfig struct {
	Destination      string                        `json:"destination"`
	Type             apiv1.BackupStorageType       `json:"type"`
	VerifyTLS        bool                          `json:"verifyTLS,omitempty"`
	ContainerOptions *apiv1.BackupContainerOptions `json:"containerOptions,omitempty"`
	S3               BackupConfigS3                `json:"s3"`
	GCS              BackupConfigGCS               `json:"gcs"`
	Azure            BackupConfigAzure             `json:"azure"`

	// Specify for incremental backups
	IncrementalLsn string `json:"incrementalLsn,omitempty"`
}

func GetBackupConfig added in v0.12.0 

func GetBackupConfig(ctx context.Context, cl client.Client, cr *apiv1.PerconaServerMySQLBackup) (*BackupConfig, error)

func (*BackupConfig) XbcloudDeleteArgs added in v1.1.0 

func (conf *BackupConfig) XbcloudDeleteArgs() []string

func (*BackupConfig) XbcloudGetArgs added in v1.1.0 

func (conf *BackupConfig) XbcloudGetArgs(files ...string) []string

func (*BackupConfig) XbcloudPutArgs added in v1.1.0 

func (conf *BackupConfig) XbcloudPutArgs() []string

type BackupConfigAzure added in v1.0.0 

type BackupConfigAzure struct {
	ContainerName  string `json:"containerName"`
	EndpointURL    string `json:"endpointUrl,omitempty"`
	StorageClass   string `json:"storageClass,omitempty"`
	StorageAccount string `json:"storageAccount,omitempty"`
	AccessKey      string `json:"accessKey,omitempty"`
}

type BackupConfigGCS added in v1.0.0 

type BackupConfigGCS struct {
	Bucket       string `json:"bucket"`
	EndpointURL  string `json:"endpointUrl,omitempty"`
	StorageClass string `json:"storageClass,omitempty"`
	AccessKey    string `json:"accessKey,omitempty"`
	SecretKey    string `json:"secretKey,omitempty"`
}

type BackupConfigS3 added in v1.0.0 

type BackupConfigS3 struct {
	Bucket       string `json:"bucket"`
	Region       string `json:"region,omitempty"`
	EndpointURL  string `json:"endpointUrl,omitempty"`
	StorageClass string `json:"storageClass,omitempty"`
	AccessKey    string `json:"accessKey,omitempty"`
	SecretKey    string `json:"secretKey,omitempty"`
}

type CheckpointInfo added in v1.1.0 

type CheckpointInfo struct {
	BackupType string `json:"backup_type"`
	FromLSN    string `json:"from_lsn"`
	ToLSN      string `json:"to_lsn"`
	LastLSN    string `json:"last_lsn"`
	FlushedLSN string `json:"flushed_lsn"`
	RedoMemory string `json:"redo_memory"`
	RedoFrames string `json:"redo_frames"`
}

func (*CheckpointInfo) ParseFrom added in v1.1.0 

func (info *CheckpointInfo) ParseFrom(r io.Reader) error

type DestinationInfo added in v1.1.0 

type DestinationInfo struct {
	Base         string
	Incrementals []string
}

type NewSidecarClientFunc added in v0.7.0 

type NewSidecarClientFunc func(srcNode string) SidecarClient

type SidecarClient added in v0.7.0 

type SidecarClient interface {
	GetRunningBackupConfig(ctx context.Context) (*BackupConfig, error)
	DeleteBackup(ctx context.Context, name string, cfg BackupConfig) error
	GetCheckpointInfo(ctx context.Context, cfg BackupConfig) (*CheckpointInfo, error)
}

func NewSidecarClient added in v0.7.0 

func NewSidecarClient(srcNode string) SidecarClient

type XBCloudAction added in v0.3.0 

type XBCloudAction string
const (
	XBCloudActionPut    XBCloudAction = "put"
	XBCloudActionDelete XBCloudAction = "delete"
	XBCloudActionGet    XBCloudAction = "get"
)

Source Files

View all Source files

Directories

Path Synopsis
fake

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.