common

Documentation

Index

• func DynamicWaitForDeletion(dynamicClient dynamic.Interface, gvr schema.GroupVersionResource, ...) error
• func GetHiveNamespaceOrDie() string
• func GetHiveOperatorNamespaceOrDie() string
• func GetMachinePool(cd *hivev1.ClusterDeployment, poolName string) *hivev1.MachinePool
• func JSONDiff(a, b interface{}) ([]byte, error)
• func MustGetAPIRegistrationClient() apiregv1client.ApiregistrationV1Interface
• func MustGetClient() client.Client
• func MustGetClientFromConfig(cfg *rest.Config) client.Client
• func MustGetClusterDeployment() *hivev1.ClusterDeployment
• func MustGetClusterDeploymentClientConfig() *rest.Config
• func MustGetConfig() *rest.Config
• func MustGetDynamicClient() dynamic.Interface
• func MustGetHiveClient() hiveclient.Interface
• func MustGetInstalledClusterDeployment() *hivev1.ClusterDeployment
• func MustGetKubernetesClient() kclient.Interface
• func WaitForAPIService(c apiregv1client.ApiregistrationV1Interface, name string, ...) error
• func WaitForAPIServiceAvailable(c apiregv1client.ApiregistrationV1Interface, name string, ...) error
• func WaitForDeployment(c kclient.Interface, namespace, name string, ...) error
• func WaitForDeploymentReady(c kclient.Interface, namespace, name string, timeOut time.Duration) error
• func WaitForMachinePoolNameLease(config *rest.Config, namespace, poolName string, timeOut time.Duration) (string, error)
• func WaitForMachineSets(cfg *rest.Config, testFunc func([]*machinev1.MachineSet) bool, ...) error
• func WaitForMachines(cfg *rest.Config, testFunc func([]*machinev1.Machine) bool, ...) error
• func WaitForNodes(cfg *rest.Config, testFunc func([]*corev1.Node) bool, timeOut time.Duration) error
• func WaitForService(c kclient.Interface, namespace, name string, ...) error

Functions

func DynamicWaitForDeletion

func DynamicWaitForDeletion(dynamicClient dynamic.Interface, gvr schema.GroupVersionResource, namespace, name string, logger log.FieldLogger) error

DynamicWaitForDeletion uses the dynamic client to wait for a resource to not exist.

func GetHiveNamespaceOrDie

func GetHiveNamespaceOrDie() string

func GetHiveOperatorNamespaceOrDie

func GetHiveOperatorNamespaceOrDie() string

func GetMachinePool

func GetMachinePool(cd *hivev1.ClusterDeployment, poolName string) *hivev1.MachinePool

func JSONDiff

func JSONDiff(a, b interface{}) ([]byte, error)

func MustGetAPIRegistrationClient

func MustGetAPIRegistrationClient() apiregv1client.ApiregistrationV1Interface

func MustGetClient

func MustGetClient() client.Client

func MustGetClientFromConfig

func MustGetClientFromConfig(cfg *rest.Config) client.Client

func MustGetClusterDeployment

func MustGetClusterDeployment() *hivev1.ClusterDeployment

func MustGetClusterDeploymentClientConfig

func MustGetClusterDeploymentClientConfig() *rest.Config

func MustGetConfig

func MustGetConfig() *rest.Config

func MustGetDynamicClient

func MustGetDynamicClient() dynamic.Interface

func MustGetHiveClient

func MustGetHiveClient() hiveclient.Interface

func MustGetInstalledClusterDeployment

func MustGetInstalledClusterDeployment() *hivev1.ClusterDeployment

func MustGetKubernetesClient

func MustGetKubernetesClient() kclient.Interface

func WaitForAPIService

func WaitForAPIService(c apiregv1client.ApiregistrationV1Interface, name string, testFunc func(*apiregv1.APIService) bool, timeOut time.Duration) error

func WaitForAPIServiceAvailable

func WaitForAPIServiceAvailable(c apiregv1client.ApiregistrationV1Interface, name string, timeOut time.Duration) error

func WaitForDeployment

func WaitForDeployment(c kclient.Interface, namespace, name string, testFunc func(*appsv1.Deployment) bool, timeOut time.Duration) error

func WaitForDeploymentReady

func WaitForDeploymentReady(c kclient.Interface, namespace, name string, timeOut time.Duration) error

func WaitForMachinePoolNameLease

func WaitForMachinePoolNameLease(config *rest.Config, namespace, poolName string, timeOut time.Duration) (string, error)

WaitForMachinePoolNameLease waits for a lease to appear in the given namespace for the given pool.

func WaitForMachineSets

func WaitForMachineSets(cfg *rest.Config, testFunc func([]*machinev1.MachineSet) bool, timeOut time.Duration) error

func WaitForMachines

func WaitForMachines(cfg *rest.Config, testFunc func([]*machinev1.Machine) bool, timeOut time.Duration) error

func WaitForNodes

func WaitForNodes(cfg *rest.Config, testFunc func([]*corev1.Node) bool, timeOut time.Duration) error

func WaitForService

func WaitForService(c kclient.Interface, namespace, name string, testFunc func(*corev1.Service) bool, timeOut time.Duration) error