Versions in this module Expand all Collapse all v0 v0.4.0 Jun 17, 2020 Changes in this version + const DefaultNamespaceDeletionTimeout + const PodStartTimeout + const Poll + const RecommendedConfigPathEnvVar + var OrchestratorPort = 3000 + var POLLING = 2 * time.Second + func BackupCompleted() gomegatypes.GomegaMatcher + func CreateTestingNS(baseName string, c clientset.Interface, labels map[string]string) (*corev1.Namespace, error) + func DeleteNS(c clientset.Interface, namespace string, timeout time.Duration) error + func Failf(format string, args ...interface{}) + func GetBucketName() string + func GetClusterLabels(cluster *api.MysqlCluster) labels.Set + func GetNameForJob(backup *api.MysqlBackup) string + func GetNameForResource(name string, cluster *api.MysqlCluster) string + func GetPodLogs(c clientset.Interface, namespace, podName, containerName string) (string, error) + func HaveBackupCond(condType api.BackupConditionType, status corev1.ConditionStatus) gomegatypes.GomegaMatcher + func HaveClusterCond(condType api.ClusterConditionType, status corev1.ConditionStatus) gomegatypes.GomegaMatcher + func HaveClusterReplicas(replicas int) gomegatypes.GomegaMatcher + func HelmInstallChart(release, ns string) + func HelmPurgeRelease(release string) + func LoadConfig() (*restclient.Config, error) + func LogContainersInPodsWithLabels(c clientset.Interface, ns string, match map[string]string, ...) + func LogPodsWithLabels(c clientset.Interface, ns string, match map[string]string, ...) + func Logf(format string, args ...interface{}) + func NewBackup(cluster *api.MysqlCluster, bucket string) *api.MysqlBackup + func NewCluster(name, ns string) *api.MysqlCluster + func NewClusterSecret(name, ns, pw string) *corev1.Secret + func OrcClusterName(cluster *api.MysqlCluster) string + func RegisterCommonFlags() + func RegisterParseFlags() + func RemoveCleanupAction(p CleanupActionHandle) + func RestclientConfig(kubeContext string) (*clientcmdapi.Config, error) + func RunCleanupActions() + type CleanupActionHandle *int + func AddCleanupAction(fn func()) CleanupActionHandle + type Framework struct + BaseName string + Client client.Client + ClientSet clientset.Interface + Namespace *core.Namespace + OrcClient orc.Interface + SkipNamespaceCreation bool + Timeout time.Duration + func NewFramework(baseName string) *Framework + func (f *Framework) AfterEach() + func (f *Framework) BeforeEach() + func (f *Framework) ClusterEventuallyCondition(cluster *api.MysqlCluster, condType api.ClusterConditionType, ...) + func (f *Framework) CreateNamespace(labels map[string]string) (*core.Namespace, error) + func (f *Framework) ExecSQLOnNode(cluster *api.MysqlCluster, i int, user, password, query string) *sql.Rows + func (f *Framework) GetClusterPVCsFn(cluster *api.MysqlCluster) func() []corev1.PersistentVolumeClaim + func (f *Framework) GetPodForNode(cluster *api.MysqlCluster, i int) *corev1.Pod + func (f *Framework) GetPodHostname(cluster *api.MysqlCluster, p int) string + func (f *Framework) NewGCSBackupSecret() *corev1.Secret + func (f *Framework) NodeEventuallyCondition(cluster *api.MysqlCluster, nodeName string, condType api.NodeConditionType, ...) + func (f *Framework) ReadSQLTest(cluster *api.MysqlCluster, pod int, pw string) string + func (f *Framework) RefreshBackupFn(backup *api.MysqlBackup) func() *api.MysqlBackup + func (f *Framework) RefreshClusterFn(cluster *api.MysqlCluster) func() *api.MysqlCluster + func (f *Framework) WaitForPodReady(podName string) error + func (f *Framework) WriteSQLTest(cluster *api.MysqlCluster, pod int, pw string) string + type TestContextType struct + ChartPath string + ChartValues string + DumpLogsOnFailure bool + KubeConfig string + KubeContext string + KubeHost string + OperatorImage string + OrchestratorImage string + ReportDir string + SidecarImage string + TimeoutSeconds int + var TestContext TestContextType
Go to main page