cluster

func WaitForBackupAvailable ¶ added in v1.2.0

func WaitForBackupAvailable(c *kc.Client, clusterName, backupName string, timeout time.Duration) error

func WaitForBackupCondition ¶ added in v1.2.0

func WaitForBackupCondition(c *kc.Client, clusterName, backupName, conditionDesc string, timeout time.Duration, condition backupCondition) error

func WaitForBackupNotFound ¶ added in v1.2.0

func WaitForBackupNotFound(c *kc.Client, clusterName, backupName string, timeout time.Duration) error

func WaitForCertInit ¶ added in v1.3.1

func WaitForCertInit(c *kc.Client, clusterName string, timeout time.Duration) error

func WaitForCertUpdated ¶ added in v1.3.1

func WaitForCertUpdated(c *kc.Client, clusterName string, latestTime metav1.Time, timeout time.Duration) error

func WaitForClusterCondition ¶

func WaitForClusterCondition(c *kc.Client, clusterName, conditionDesc string, timeout time.Duration, condition clusterCondition, outLog bool) error

WaitForClusterCondition waits a cluster to be matched to the given condition.

func WaitForClusterHealthy ¶

func WaitForClusterHealthy(c *kc.Client, clusterName string, timeout time.Duration) error

func WaitForClusterNotFound ¶

func WaitForClusterNotFound(c *kc.Client, clusterName string, timeout time.Duration) error

WaitForClusterNotFound returns an error if it takes too long for the pod to fully terminate. Unlike `waitForPodTerminatedInNamespace`, the pod's Phase and Reason are ignored. If the pod Get api returns IsNotFound then the wait stops and nil is returned. If the Get api returns an error other than "not found" then that error is returned and the wait stops.

func WaitForClusterRunning ¶

func WaitForClusterRunning(c *kc.Client, clusterName string, timeout time.Duration) error

func WaitForComponentNotFound ¶ added in v1.2.0

func WaitForComponentNotFound(c *kc.Client, clusterName string, timeout time.Duration) error

func WaitForCriRegistry ¶ added in v1.3.1

func WaitForCriRegistry(c *kc.Client, clusterName string, timeout time.Duration, registries []string) error

func WaitForJoinNode ¶ added in v1.3.1

func WaitForJoinNode(c *kc.Client, nodeIP string, timeout time.Duration) error

func WaitForRecovery ¶ added in v1.2.0

func WaitForRecovery(c *kc.Client, clusterName string, timeout time.Duration) error

func WaitForUpgrade ¶ added in v1.2.0

func WaitForUpgrade(c *kc.Client, clusterName string, timeout time.Duration) error