util

Documentation

Index

• func CheckAllKeysExistInSecret(secret *corev1.Secret, keys ...string) (string, bool)
• func GenerateGcsCertEnvVar(gcs *v1alpha1.GcsStorageProvider) ([]corev1.EnvVar, string, error)
• func GenerateS3CertEnvVar(s3 *v1alpha1.S3StorageProvider, useKMS bool) ([]corev1.EnvVar, string, error)
• func GenerateStorageCertEnv(ns string, useKMS bool, provider v1alpha1.StorageProvider, ...) ([]corev1.EnvVar, string, error)
• func GenerateTidbPasswordEnv(ns, name, tidbSecretName string, useKMS bool, kubeCli kubernetes.Interface) ([]corev1.EnvVar, string, error)
• func GetBackupBucketName(backup *v1alpha1.Backup) (string, string, error)
• func GetBackupDataPath(provider v1alpha1.StorageProvider) (string, string, error)
• func GetBackupPrefixName(backup *v1alpha1.Backup) (string, string, error)
• func GetStorageType(provider v1alpha1.StorageProvider) v1alpha1.BackupStorageType
• func ParseImage(image string) (string, string)
• func ValidateBackup(backup *v1alpha1.Backup) error
• func ValidateRestore(restore *v1alpha1.Restore) error

Functions

func CheckAllKeysExistInSecret

func CheckAllKeysExistInSecret(secret *corev1.Secret, keys ...string) (string, bool)

CheckAllKeysExistInSecret check if all keys are included in the specific secret

func GenerateGcsCertEnvVar

func GenerateGcsCertEnvVar(gcs *v1alpha1.GcsStorageProvider) ([]corev1.EnvVar, string, error)

GenerateGcsCertEnvVar generate the env info in order to access google cloud storage

func GenerateS3CertEnvVar

func GenerateS3CertEnvVar(s3 *v1alpha1.S3StorageProvider, useKMS bool) ([]corev1.EnvVar, string, error)

GenerateS3CertEnvVar generate the env info in order to access S3 compliant storage

func GenerateStorageCertEnv

func GenerateStorageCertEnv(ns string, useKMS bool, provider v1alpha1.StorageProvider, kubeCli kubernetes.Interface) ([]corev1.EnvVar, string, error)

GenerateStorageCertEnv generate the env info in order to access backend backup storage

func GenerateTidbPasswordEnv

func GenerateTidbPasswordEnv(ns, name, tidbSecretName string, useKMS bool, kubeCli kubernetes.Interface) ([]corev1.EnvVar, string, error)

GenerateTidbPasswordEnv generate the password EnvVar

func GetBackupBucketName

func GetBackupBucketName(backup *v1alpha1.Backup) (string, string, error)

GetBackupBucketName return the bucket name for remote storage

func GetBackupDataPath

func GetBackupDataPath(provider v1alpha1.StorageProvider) (string, string, error)

GetBackupDataPath return the full path of backup data

func GetBackupPrefixName

func GetBackupPrefixName(backup *v1alpha1.Backup) (string, string, error)

GetBackupPrefixName return the prefix for remote storage

func GetStorageType

func GetStorageType(provider v1alpha1.StorageProvider) v1alpha1.BackupStorageType

GetStorageType return the backup storage type according to the specified StorageProvider

func ParseImage

func ParseImage(image string) (string, string)

ParseImage returns the image name and the tag from the input image string

func ValidateBackup

func ValidateBackup(backup *v1alpha1.Backup) error

func ValidateRestore

func ValidateRestore(restore *v1alpha1.Restore) error

ValidateRestore checks whether a restore spec is valid.