const Removed … const Terminating … const Other … func pluginPVOmittingClient(dswp *desiredStateOfWorldPopulator) { … } func prepareDswpWithVolume(t *testing.T) (*desiredStateOfWorldPopulator, kubepod.Manager, *fakePodStateProvider) { … } func TestFindAndAddNewPods_WithDifferentConditions(t *testing.T) { … } func TestFindAndAddNewPods_WithReprocessPodAndVolumeRetrievalError(t *testing.T) { … } func TestFindAndAddNewPods_WithVolumeRetrievalError(t *testing.T) { … } type mutablePodManager … func TestFindAndAddNewPods_FindAndRemoveDeletedPods(t *testing.T) { … } func TestFindAndRemoveDeletedPodsWithActualState(t *testing.T) { … } func TestFindAndRemoveDeletedPodsWithUncertain(t *testing.T) { … } func prepareDSWPWithPodPV(t *testing.T) (*desiredStateOfWorldPopulator, *fakePodStateProvider, *v1.Pod, v1.UniqueVolumeName, *v1.PersistentVolume) { … } func TestFindAndRemoveNonattachableVolumes(t *testing.T) { … } func TestEphemeralVolumeOwnerCheck(t *testing.T) { … } func TestFindAndAddNewPods_FindAndRemoveDeletedPods_Valid_Block_VolumeDevices(t *testing.T) { … } func TestCreateVolumeSpec_Valid_File_VolumeMounts(t *testing.T) { … } func TestCreateVolumeSpec_Valid_Nil_VolumeMounts(t *testing.T) { … } func TestCreateVolumeSpec_Valid_Block_VolumeDevices(t *testing.T) { … } func TestCreateVolumeSpec_Invalid_File_VolumeDevices(t *testing.T) { … } func TestCreateVolumeSpec_Invalid_Block_VolumeMounts(t *testing.T) { … } func TestCheckVolumeFSResize(t *testing.T) { … } func TestCheckVolumeSELinux(t *testing.T) { … } func createResizeRelatedVolumes(volumeMode *v1.PersistentVolumeMode) (pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim) { … } func volumeCapacity(size int) v1.ResourceList { … } func reconcileASW(asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld, t *testing.T) { … } func clearASW(asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld, t *testing.T) { … } func reprocess(ctx context.Context, dswp *desiredStateOfWorldPopulator, uniquePodName types.UniquePodName, dsw cache.DesiredStateOfWorld, asw cache.ActualStateOfWorld, newSize resource.Quantity) []v1.UniqueVolumeName { … } func getResizeRequiredVolumes(dsw cache.DesiredStateOfWorld, asw cache.ActualStateOfWorld, newSize resource.Quantity) []v1.UniqueVolumeName { … } func verifyVolumeExistsInVolumesToMount(t *testing.T, expectedVolumeName v1.UniqueVolumeName, expectReportedInUse bool, dsw cache.DesiredStateOfWorld) { … } func createPodWithVolume(pod, pv, pvc string, containers []v1.Container) *v1.Pod { … } func createEphemeralVolumeObjects(podName, volumeName string, owned bool, volumeMode *v1.PersistentVolumeMode) (pod *v1.Pod, pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim) { … } func createDswpWithVolume(t *testing.T, pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim) (*desiredStateOfWorldPopulator, kubepod.Manager, cache.DesiredStateOfWorld, *containertest.FakeRuntime, *fakePodStateProvider) { … } type fakePodStateProvider … func (p *fakePodStateProvider) ShouldPodContainersBeTerminating(uid kubetypes.UID) bool { … } func (p *fakePodStateProvider) ShouldPodRuntimeBeRemoved(uid kubetypes.UID) bool { … } func createDswpWithVolumeWithCustomPluginMgr(pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim, fakeVolumePluginMgr *volume.VolumePluginMgr) (*desiredStateOfWorldPopulator, kubepod.Manager, cache.DesiredStateOfWorld, *containertest.FakeRuntime, *fakePodStateProvider) { … }