Documentation
¶
Index ¶
- func DeleteJobName(cr *apiv1.PerconaServerMySQLBackup) string
- func DeleteName(cr *apiv1.PerconaServerMySQLBackup) string
- func GetDeleteJob(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLBackup, ...) *batchv1.Job
- func GetDestination(storage *apiv1.BackupStorageSpec, clusterName, creationTimeStamp string) (apiv1.BackupDestination, error)
- func Job(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLBackup, ...) (*batchv1.Job, error)
- func JobName(cr *apiv1.PerconaServerMySQLBackup) string
- func JobNamespacedName(cr *apiv1.PerconaServerMySQLBackup) types.NamespacedName
- func Name(cr *apiv1.PerconaServerMySQLBackup) string
- func PVC(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLBackup, ...) *corev1.PersistentVolumeClaim
- func RestoreJob(cluster *apiv1.PerconaServerMySQL, destination apiv1.BackupDestination, ...) *batchv1.Job
- func RestoreJobName(cluster *apiv1.PerconaServerMySQL, cr *apiv1.PerconaServerMySQLRestore) string
- func RestoreName(cr *apiv1.PerconaServerMySQLRestore) string
- func SetSourceNode(job *batchv1.Job, src string) error
- func SetStorageAzure(job *batchv1.Job, azure *apiv1.BackupStorageAzureSpec) error
- func SetStorageGCS(job *batchv1.Job, gcs *apiv1.BackupStorageGCSSpec) error
- func SetStoragePVC(job *batchv1.Job, pvc *corev1.PersistentVolumeClaim) error
- func SetStorageS3(job *batchv1.Job, s3 *apiv1.BackupStorageS3Spec) error
- func XBCloudArgs(action XBCloudAction, conf *BackupConfig) []string
- type BackupConfig
- type NewSidecarClientFunc
- type SidecarClient
- type XBCloudAction
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, clusterName, creationTimeStamp string) (apiv1.BackupDestination, error)
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 apiv1.BackupDestination, 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 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
func XBCloudArgs ¶ added in v0.3.0
func XBCloudArgs(action XBCloudAction, conf *BackupConfig) []string
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 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"` } `json:"s3,omitempty"` GCS 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"` } `json:"gcs,omitempty"` Azure 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"` } `json:"azure,omitempty"` }
func GetBackupConfig ¶ added in v0.12.0
func GetBackupConfig(ctx context.Context, cl client.Client, cr *apiv1.PerconaServerMySQLBackup) (*BackupConfig, error)
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 }
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" )
Click to show internal directories.
Click to hide internal directories.