cluster

func ClusterConfig ¶

func ClusterConfig(clusterID string) (restConfig *rest.Config, providerType string, err error)

ClusterConfig returns the rest API config for a given cluster as well as the provider it inferred to discover the config. param clusterID: If specified, Provider will be discovered through OCM. If the empty string, assume we are running in a cluster and use in-cluster REST config instead.

func GetClusterVersion ¶

func GetClusterVersion(provider spi.Provider, clusterID string) (*semver.Version, error)

GetClusterVersion will get the current cluster version for the cluster.

func PollClusterHealth ¶

func PollClusterHealth(clusterID string, logger *log.Logger) (status bool, failures []string, err error)

PollClusterHealth looks at CVO data to determine if a cluster is alive/healthy or not param clusterID: If specified, Provider will be discovered through OCM. If the empty string, assume we are running in a cluster and use in-cluster REST config instead.

func ProvisionCluster ¶

func ProvisionCluster(logger *log.Logger) (*spi.Cluster, error)

ProvisionCluster will provision a cluster and immediately return.

func ScaleCluster ¶

func ScaleCluster(clusterID string, numComputeNodes int) error

ScaleCluster will scale the cluster up to the provided size.

func WaitForClusterReadyPostInstall ¶

func WaitForClusterReadyPostInstall(clusterID string, logger *log.Logger) error

WaitForClusterReadyPostInstall blocks until the cluster is ready for testing using mechanisms appropriate for a newly-installed cluster.

func WaitForClusterReadyPostScale ¶

func WaitForClusterReadyPostScale(clusterID string, logger *log.Logger) error

WaitForClusterReadyPostScale blocks until the cluster is ready for testing and uses healthcheck mechanisms appropriate for after the cluster has been scaled.

func WaitForClusterReadyPostUpgrade ¶

func WaitForClusterReadyPostUpgrade(clusterID string, logger *log.Logger) error

WaitForClusterReadyPostUpgrade blocks until the cluster is ready for testing using healthcheck mechanisms appropriate for after a cluster version upgrade.

func WaitForClusterReadyPostWake ¶

func WaitForClusterReadyPostWake(clusterID string, logger *log.Logger) error

WaitForClusterReadyPostWake blocks until the cluster is ready for testing, deletes errored pods, and then uses healthcheck mechanisms appropriate for after the cluster resumed from hibernation.

func WaitForOCMProvisioning ¶

func WaitForOCMProvisioning(provider spi.Provider, clusterID string, logger *log.Logger, isUpgrade bool) (becameReadyAt time.Time, err error)