kubernetes/pkg/kubelet/volumemanager/volume_manager_test.go

const testHostname …

func TestGetMountedVolumesForPodAndGetVolumesInUse(t *testing.T) { … }

func TestWaitForAttachAndMountError(t *testing.T) { … }

func TestInitialPendingVolumesForPodAndGetVolumesInUse(t *testing.T) { … }

func TestGetExtraSupplementalGroupsForPod(t *testing.T) { … }

type fakePodStateProvider …

func (p *fakePodStateProvider) ShouldPodRuntimeBeRemoved(uid kubetypes.UID) bool { … }

func (p *fakePodStateProvider) ShouldPodContainersBeTerminating(uid kubetypes.UID) bool { … }

func newTestVolumeManager(t *testing.T, tmpDir string, podManager kubepod.Manager, kubeClient clientset.Interface, node *v1.Node) VolumeManager { … }

// createObjects returns objects for making a fake clientset. The pv is
// already attached to the node and bound to the claim used by the pod.
func createObjects(pvMode, podMode v1.PersistentVolumeMode) (*v1.Node, *v1.Pod, *v1.PersistentVolume, *v1.PersistentVolumeClaim) { … }

func simulateVolumeInUseUpdate(volumeName v1.UniqueVolumeName, stopCh <-chan struct{ … }

func delayClaimBecomesBound(
	kubeClient clientset.Interface,
	namespace, claimName string,
) { … }

func TestWaitForAllPodsUnmount(t *testing.T) { … }