Documentation
¶
Index ¶
- Constants
- func GetAndCheckBackup(c client.Client, ns, name string, check func(b *v1alpha1.Backup) bool) error
- func GetBackup(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.Backup
- func GetCompactBackup(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.CompactBackup
- func GetRestore(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.Restore
- func GetRole(ns string) *rbacv1.Role
- func GetRoleBinding(ns string) *rbacv1.RoleBinding
- func GetSecret(ns, name, password string) *corev1.Secret
- func GetServiceAccount(ns string) *corev1.ServiceAccount
- func LoadClientRawConfig() (clientcmdapi.Config, error)
- func WaitAndDeleteRunningBackupPod(f *Framework, backup *v1alpha1.Backup, timeout time.Duration) error
- func WaitBackupPodOnPhase(f *Framework, backup *v1alpha1.Backup, phase corev1.PodPhase, ...) error
- func WaitForBackup(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForBackupComplete(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForBackupDeleted(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForBackupFailed(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForBackupOnRunning(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForBackupOnScheduled(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForLogBackupProgressReachTS(c client.Client, ns, name, expect string, timeout time.Duration) error
- func WaitForLogBackupReachTS(name, pdhost, expect string, timeout time.Duration) error
- func WaitForRestoreComplete(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForRestoreDeleted(c client.Client, ns, name string, timeout time.Duration) error
- func WaitForRestoreProgressDone(c client.Client, ns, name string, timeout time.Duration) error
- type Framework
Constants ¶
const ( BRType = "br" DumperType = "dumper" )
Variables ¶
This section is empty.
Functions ¶
func GetAndCheckBackup ¶
func GetBackup ¶
func GetBackup(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.Backup
GetBackup return a basic backup
func GetCompactBackup ¶
func GetCompactBackup(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.CompactBackup
func GetRestore ¶
func GetRestore(ns, name, tcName string, s3Config *v1alpha1.S3StorageProvider) *v1alpha1.Restore
func GetRoleBinding ¶
func GetRoleBinding(ns string) *rbacv1.RoleBinding
GetRoleBinding returns a rolebinding for br test.
func GetServiceAccount ¶
func GetServiceAccount(ns string) *corev1.ServiceAccount
GetServiceAccount returns a sa for br test.
func LoadClientRawConfig ¶
func LoadClientRawConfig() (clientcmdapi.Config, error)
func WaitBackupPodOnPhase ¶
func WaitForBackup ¶
WaitForBackup will poll and wait until timeout
func WaitForBackupComplete ¶
WaitForBackupComplete will poll and wait until timeout or backup complete condition is true
func WaitForBackupDeleted ¶
WaitForBackupDeleted will poll and wait until timeout or backup is really deleted
func WaitForBackupFailed ¶
WaitForBackupFailed will poll and wait until timeout or backup failed condition is true
func WaitForBackupOnRunning ¶
WaitForBackupOnRunning will poll and wait until timeout or backup phause is running
func WaitForBackupOnScheduled ¶
WaitForBackupOnRunning will poll and wait until timeout or backup phause is schedule
func WaitForLogBackupProgressReachTS ¶
func WaitForLogBackupProgressReachTS(c client.Client, ns, name, expect string, timeout time.Duration) error
WaitForLogBackupProgressReachTS will poll and wait until timeout or log backup tracker has update checkpoint ts to expect
func WaitForLogBackupReachTS ¶
WaitForLogBackupReachTS will poll and wait until timeout or log backup reach expect ts
func WaitForRestoreComplete ¶
WaitForRestoreComplete will poll and wait until timeout or restore complete condition is true
func WaitForRestoreDeleted ¶
WaitForRestoreDeleted will poll and wait until timeout or restore is really deleted
Types ¶
type Framework ¶
type Framework struct {
*framework.Framework
// PortForwarder is defined to visit pod in local.
PortForwarder k8s.PortForwarder
// Storage defines interface of s3 storage
Storage s3.Interface
YamlApplier *k8s.YAMLApplier
}
Source Files