Versions in this module Expand all Collapse all v1 v1.0.2 Jan 29, 2025 Changes in this version + func ExecPodWithRetries(ctx context.Context, config *restclient.Config, k8s *kubernetes.Clientset, ...) (stdout, stderr string, err error) + func GetDaemonSet(ctx context.Context, logger logr.Logger, k8s *kubernetes.Clientset, ...) (*appsv1.DaemonSet, error) + func GetPodLogsWithRetries(ctx context.Context, k8s *kubernetes.Clientset, name, namespace string) (logs string, err error) v1.0.1 Jan 16, 2025 Changes in this version + const MinimumVersion + func CordonNode(ctx context.Context, k8s *kubernetes.Clientset, node *corev1.Node, ...) error + func CreateNginxPodInNode(ctx context.Context, k8s *kubernetes.Clientset, ...) error + func DeleteNode(ctx context.Context, k8s *kubernetes.Clientset, name string) error + func DeletePod(ctx context.Context, k8s *kubernetes.Clientset, name, namespace string) error + func DrainNode(ctx context.Context, k8s *kubernetes.Clientset, node *corev1.Node) error + func EnsureNodeWithIPIsDeleted(ctx context.Context, k8s *kubernetes.Clientset, internalIP string) error + func ExecPod(ctx context.Context, config *restclient.Config, k8s *kubernetes.Clientset, ...) (stdout, stderr string, err error) + func GetNginxPodName(name string) string + func GetPodLogs(ctx context.Context, k8s *kubernetes.Clientset, name, namespace string) (string, error) + func IsPreviousVersionSupported(kubernetesVersion string) (bool, error) + func PreviousVersion(kubernetesVersion string) (string, error) + func UncordonNode(ctx context.Context, k8s *kubernetes.Clientset, node *corev1.Node) error + func WaitForHybridNodeToBeNotReady(ctx context.Context, k8s *kubernetes.Clientset, nodeName string, ...) error + func WaitForHybridNodeToBeReady(ctx context.Context, k8s *kubernetes.Clientset, nodeName string, ...) error + func WaitForNode(ctx context.Context, k8s *kubernetes.Clientset, internalIP string, ...) (*corev1.Node, error) + func WaitForNodeToHaveVersion(ctx context.Context, k8s *kubernetes.Clientset, nodeName, targetVersion string, ...) (*corev1.Node, error) + type VerifyNode struct + ClientConfig *rest.Config + K8s *clientgo.Clientset + Logger logr.Logger + NodeIPAddress string + Region string + func (t VerifyNode) Run(ctx context.Context) error
Go to main page