kubernetes/test/e2e_node/mirror_pod_test.go

var _ …

func podVolumeDirectoryExists(uid types.UID) bool { … }

// Restart the passed-in nfs-server by issuing a `/usr/sbin/rpc.nfsd 1` command in the
// pod's (only) container. This command changes the number of nfs server threads from
// (presumably) zero back to 1, and therefore allows nfs to open connections again.
func restartNfsServer(f *framework.Framework, serverPod *v1.Pod) { … }

// Stop the passed-in nfs-server by issuing a `/usr/sbin/rpc.nfsd 0` command in the
// pod's (only) container. This command changes the number of nfs server threads to 0,
// thus closing all open nfs connections.
func stopNfsServer(f *framework.Framework, serverPod *v1.Pod) { … }

func createStaticPodUsingNfs(nfsIP string, nodeName string, cmd string, dir string, name string, ns string) error { … }

func staticPodPath(dir, name, namespace string) string { … }

func createStaticPod(dir, name, namespace, image string, restart v1.RestartPolicy) error { … }

func deleteStaticPod(dir, name, namespace string) error { … }

func checkMirrorPodDisappear(ctx context.Context, cl clientset.Interface, name, namespace string) error { … }

func checkMirrorPodRunning(ctx context.Context, cl clientset.Interface, name, namespace string) error { … }

func checkMirrorPodRunningWithRestartCount(ctx context.Context, interval time.Duration, timeout time.Duration, cl clientset.Interface, name, namespace string, count int32) error { … }

func checkMirrorPodRecreatedAndRunning(ctx context.Context, cl clientset.Interface, name, namespace string, oUID types.UID) error { … }

func validateMirrorPod(ctx context.Context, cl clientset.Interface, mirrorPod *v1.Pod) error { … }