kubernetes/test/e2e/storage/testsuites/subpath.go

var volumePath …

var volumeName …

var probeVolumePath …

var probeFilePath …

var fileName …

var retryDuration …

type subPathTestSuite …

// InitCustomSubPathTestSuite returns subPathTestSuite that implements TestSuite interface
// using custom test patterns
func InitCustomSubPathTestSuite(patterns []storageframework.TestPattern) storageframework.TestSuite { … }

// InitSubPathTestSuite returns subPathTestSuite that implements TestSuite interface
// using testsuite default patterns
func InitSubPathTestSuite() storageframework.TestSuite { … }

func (s *subPathTestSuite) GetTestSuiteInfo() storageframework.TestSuiteInfo { … }

func (s *subPathTestSuite) SkipUnsupportedTests(driver storageframework.TestDriver, pattern storageframework.TestPattern) { … }

func (s *subPathTestSuite) DefineTests(driver storageframework.TestDriver, pattern storageframework.TestPattern) { … }

// TestBasicSubpath runs basic subpath test
func TestBasicSubpath(ctx context.Context, f *framework.Framework, contents string, pod *v1.Pod) { … }

// TestBasicSubpathFile runs basic subpath file test
func TestBasicSubpathFile(ctx context.Context, f *framework.Framework, contents string, pod *v1.Pod, filepath string) { … }

func generateSuffixForPodName(s string) string { … }

// SubpathTestPod returns a pod spec for subpath tests
func SubpathTestPod(f *framework.Framework, subpath, volumeType string, source *v1.VolumeSource, securityLevel admissionapi.Level) *v1.Pod { … }

func containerIsUnused(container *v1.Container) bool { … }

// removeUnusedContainers removes containers from a SubpathTestPod that aren't
// needed for a test. e.g. to test for subpath mount failure, only one
// container needs to run and get its status checked.
func removeUnusedContainers(pod *v1.Pod) { … }

// volumeFormatPod returns a Pod that does nothing but will cause the plugin to format a filesystem
// on first use
func volumeFormatPod(f *framework.Framework, volumeSource *v1.VolumeSource) *v1.Pod { … }

func setInitCommand(pod *v1.Pod, command string) { … }

func setWriteCommand(file string, container *v1.Container) { … }

func addSubpathVolumeContainer(container *v1.Container, volumeMount v1.VolumeMount) { … }

func addMultipleWrites(container *v1.Container, file1 string, file2 string) { … }

func testMultipleReads(ctx context.Context, f *framework.Framework, pod *v1.Pod, containerIndex int, file1 string, file2 string) { … }

func setReadCommand(file string, container *v1.Container) { … }

func testReadFile(ctx context.Context, f *framework.Framework, file string, pod *v1.Pod, containerIndex int) { … }

func testPodFailSubpath(ctx context.Context, f *framework.Framework, pod *v1.Pod, allowContainerTerminationError bool) { … }

func testPodFailSubpathError(ctx context.Context, f *framework.Framework, pod *v1.Pod, errorMsg string, allowContainerTerminationError bool) { … }

func findSubpathContainerName(pod *v1.Pod) string { … }

func waitForPodSubpathError(ctx context.Context, f *framework.Framework, pod *v1.Pod, allowContainerTerminationError bool) error { … }

type podContainerRestartHooks …

func (h *podContainerRestartHooks) AddLivenessProbe(pod *v1.Pod, probeFilePath string) { … }

func (h *podContainerRestartHooks) FailLivenessProbe(pod *v1.Pod, probeFilePath string) { … }

func (h *podContainerRestartHooks) FixLivenessProbe(pod *v1.Pod, probeFilePath string) { … }

// testPodContainerRestartWithHooks tests that container restarts to stabilize.
// hooks wrap functions between container restarts.
func testPodContainerRestartWithHooks(ctx context.Context, f *framework.Framework, pod *v1.Pod, hooks *podContainerRestartHooks) { … }

// testPodContainerRestart tests that the existing subpath mount is detected when a container restarts
func testPodContainerRestart(ctx context.Context, f *framework.Framework, pod *v1.Pod) { … }

// TestPodContainerRestartWithConfigmapModified tests that container can restart to stabilize when configmap has been modified.
// 1. valid container running
// 2. update configmap
// 3. container restarts
// 4. container becomes stable after configmap mounted file has been modified
func TestPodContainerRestartWithConfigmapModified(ctx context.Context, f *framework.Framework, original, modified *v1.ConfigMap) { … }

func testSubpathReconstruction(ctx context.Context, f *framework.Framework, hostExec storageutils.HostExec, pod *v1.Pod, forceDelete bool) { … }

func formatVolume(ctx context.Context, f *framework.Framework, pod *v1.Pod) { … }

func podContainerExec(pod *v1.Pod, containerIndex int, command string) (string, error) { … }