Documentation ¶
Index ¶
- func DeleteClusterNodes(nodes []string, clientset *kubernetes.Clientset, logger *logrus.Entry) error
- func GetClientset() (*kubernetes.Clientset, error)
- func NodesReady(nodes []string, clientset *kubernetes.Clientset, logger *logrus.Entry) error
- func WaitForNodeRunning(ctx context.Context, nodeName string, clientset *kubernetes.Clientset, ...) (*corev1.Node, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteClusterNodes ¶
func GetClientset ¶
func GetClientset() (*kubernetes.Clientset, error)
getClientSet gets the k8s clientset
func NodesReady ¶
func WaitForNodeRunning ¶
func WaitForNodeRunning(ctx context.Context, nodeName string, clientset *kubernetes.Clientset, logger *logrus.Entry) (*corev1.Node, error)
WaitForNodeRunning will poll a given kubernetes node at a regular interval for it to enter the 'Ready' state. If the node fails to become ready before the provided timeout then an error will be returned.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.