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 {}