cluster

Documentation

Index

• func ClusterConfig(clusterID string) (restConfig *rest.Config, providerType string, err error)
• func GetClusterVersion(provider spi.Provider, clusterID string) (*semver.Version, error)
• func PollClusterHealth(clusterID string, logger *log.Logger) (status bool, failures []string, err error)
• func ProvisionCluster(logger *log.Logger) (*spi.Cluster, error)
• func SetClusterIntoViperConfig(cluster *spi.Cluster)
• func WaitForClusterReadyPostInstall(clusterID string, logger *log.Logger) error
• func WaitForClusterReadyPostUpgrade(clusterID string, logger *log.Logger) error
• func WaitForClusterReadyPostWake(clusterID string, logger *log.Logger) error
• func WaitForOCMProvisioning(provider spi.Provider, clusterID string, logger *log.Logger, isUpgrade bool) (becameReadyAt time.Time, err error)

Functions

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 SetClusterIntoViperConfig

func SetClusterIntoViperConfig(cluster *spi.Cluster)

set cluster infor into viper and metadata

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 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)