Documentation
¶
Index ¶
- func DeleteJobName(cr *apiv1alpha1.PerconaServerMySQLBackup) string
- func DeleteName(cr *apiv1alpha1.PerconaServerMySQLBackup) string
- func GetDeleteJob(cr *apiv1alpha1.PerconaServerMySQLBackup, conf *BackupConfig) *batchv1.Job
- func Job(cluster *apiv1alpha1.PerconaServerMySQL, ...) *batchv1.Job
- func JobName(cr *apiv1alpha1.PerconaServerMySQLBackup) string
- func JobNamespacedName(cr *apiv1alpha1.PerconaServerMySQLBackup) types.NamespacedName
- func MatchLabels(cluster *apiv1alpha1.PerconaServerMySQL) map[string]string
- func Name(cr *apiv1alpha1.PerconaServerMySQLBackup) string
- func PVC(cluster *apiv1alpha1.PerconaServerMySQL, ...) *corev1.PersistentVolumeClaim
- func RestoreJob(cluster *apiv1alpha1.PerconaServerMySQL, ...) *batchv1.Job
- func RestoreJobName(cluster *apiv1alpha1.PerconaServerMySQL, ...) string
- func RestoreName(cr *apiv1alpha1.PerconaServerMySQLRestore) string
- func SetSourceNode(job *batchv1.Job, src string) error
- func SetStorageAzure(job *batchv1.Job, azure *apiv1alpha1.BackupStorageAzureSpec) error
- func SetStorageGCS(job *batchv1.Job, gcs *apiv1alpha1.BackupStorageGCSSpec) error
- func SetStoragePVC(job *batchv1.Job, pvc *corev1.PersistentVolumeClaim) error
- func SetStorageS3(job *batchv1.Job, s3 *apiv1alpha1.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 *apiv1alpha1.PerconaServerMySQLBackup) string
func DeleteName ¶ added in v0.3.0
func DeleteName(cr *apiv1alpha1.PerconaServerMySQLBackup) string
func GetDeleteJob ¶ added in v0.3.0
func GetDeleteJob(cr *apiv1alpha1.PerconaServerMySQLBackup, conf *BackupConfig) *batchv1.Job
func Job ¶
func Job( cluster *apiv1alpha1.PerconaServerMySQL, cr *apiv1alpha1.PerconaServerMySQLBackup, destination apiv1alpha1.BackupDestination, initImage string, storage *apiv1alpha1.BackupStorageSpec, ) *batchv1.Job
func JobName ¶
func JobName(cr *apiv1alpha1.PerconaServerMySQLBackup) string
func JobNamespacedName ¶ added in v0.9.0
func JobNamespacedName(cr *apiv1alpha1.PerconaServerMySQLBackup) types.NamespacedName
func MatchLabels ¶
func MatchLabels(cluster *apiv1alpha1.PerconaServerMySQL) map[string]string
func Name ¶
func Name(cr *apiv1alpha1.PerconaServerMySQLBackup) string
func PVC ¶
func PVC(cluster *apiv1alpha1.PerconaServerMySQL, cr *apiv1alpha1.PerconaServerMySQLBackup, storage *apiv1alpha1.BackupStorageSpec) *corev1.PersistentVolumeClaim
func RestoreJob ¶
func RestoreJob( cluster *apiv1alpha1.PerconaServerMySQL, destination apiv1alpha1.BackupDestination, restore *apiv1alpha1.PerconaServerMySQLRestore, storage *apiv1alpha1.BackupStorageSpec, initImage string, pvcName string, ) *batchv1.Job
func RestoreJobName ¶
func RestoreJobName(cluster *apiv1alpha1.PerconaServerMySQL, cr *apiv1alpha1.PerconaServerMySQLRestore) string
func RestoreName ¶
func RestoreName(cr *apiv1alpha1.PerconaServerMySQLRestore) string
func SetStorageAzure ¶
func SetStorageAzure(job *batchv1.Job, azure *apiv1alpha1.BackupStorageAzureSpec) error
func SetStorageGCS ¶
func SetStorageGCS(job *batchv1.Job, gcs *apiv1alpha1.BackupStorageGCSSpec) error
func SetStoragePVC ¶
func SetStoragePVC(job *batchv1.Job, pvc *corev1.PersistentVolumeClaim) error
func SetStorageS3 ¶
func SetStorageS3(job *batchv1.Job, s3 *apiv1alpha1.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 apiv1alpha1.BackupStorageType `json:"type"` VerifyTLS bool `json:"verifyTLS,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"` }
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.