utils

func CheckNoReboot ¶ added in v0.10.0

func CheckNoReboot(ctx context.Context, c *kubernetes.Clientset, node *corev1.Node, oldBootTime *time.Time, testNamespace string)

func CheckReboot ¶ added in v0.10.0

func CheckReboot(ctx context.Context, c *kubernetes.Clientset, node *corev1.Node, oldBootTime *time.Time, testNamespace string)

func GetBootTime ¶ added in v0.10.0

func GetBootTime(ctx context.Context, c *kubernetes.Clientset, node *corev1.Node, testNamespace string) (*time.Time, error)

GetBootTime gets the boot time of the given node by running a pod on it executing uptime command

func GetLogs ¶

func GetLogs(c *kubernetes.Clientset, pod *corev1.Pod, since *metav1.Time) (string, error)

GetLogs returns logs of the specified pod

func RunCommandInCluster ¶ added in v0.10.0

func RunCommandInCluster(ctx context.Context, c *kubernetes.Clientset, nodeName string, ns string, command string) (string, error)

RunCommandInCluster runs a command in a new pod in the cluster and returns the output

func RunCommandInPod ¶ added in v0.10.0

func RunCommandInPod(ctx context.Context, c *kubernetes.Clientset, pod *corev1.Pod, command string) (string, error)

RunCommandInPod runs a command in a given pod and returns the output

func WaitForPodReady ¶

func WaitForPodReady(c client.Client, pod *corev1.Pod)