kubernetes/pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

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