kubernetes/test/e2e/cloud/gcp/reboot.go

const rebootNodeNotReadyTimeout …

const rebootNodeReadyAgainTimeout …

const rebootPodReadyAgainTimeout …

var _ …

func testReboot(ctx context.Context, c clientset.Interface, rebootCmd string, hook terminationHook) { … }

func printStatusAndLogsForNotReadyPods(ctx context.Context, c clientset.Interface, ns string, podNames []string, pods []*v1.Pod) { … }

// rebootNode takes node name on provider through the following steps using c:
//   - ensures the node is ready
//   - ensures all pods on the node are running and ready
//   - reboots the node (by executing rebootCmd over ssh)
//   - ensures the node reaches some non-ready state
//   - ensures the node becomes ready again
//   - ensures all pods on the node become running and ready again
//
// It returns true through result only if all of the steps pass; at the first
// failed step, it will return false through result and not run the rest.
func rebootNode(ctx context.Context, c clientset.Interface, provider, name, rebootCmd string) bool { … }

type terminationHook …

func catLogHook(ctx context.Context, logPath string) terminationHook { … }

func dropPacketsScript(chainName, logPath string) string { … }