const reconcilerLoopSleepDuration … const waitForAttachTimeout … const nodeName … const kubeletPodsDir … const testOperationBackOffDuration … const reconcilerSyncWaitDuration … func hasAddedPods() bool { … } // Calls Run() // Verifies there are no calls to attach, detach, mount, unmount, etc. func Test_Run_Positive_DoNothing(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Calls Run() // Verifies there is are attach/mount/etc calls and no detach/unmount calls. func Test_Run_Positive_VolumeAttachAndMount(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Calls Run() // Verifies there is are attach/mount/etc calls and no detach/unmount calls. func Test_Run_Positive_VolumeAttachAndMountMigrationEnabled(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Verifies there is one mount call and no unmount calls. // Verifies there are no attach/detach calls. func Test_Run_Positive_VolumeMountControllerAttachEnabled(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // volume is not repored-in-use // Calls Run() // Verifies that there is not wait-for-mount call // Verifies that there is no exponential-backoff triggered func Test_Run_Negative_VolumeMountControllerAttachEnabled(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Calls Run() // Verifies there is one attach/mount/etc call and no detach calls. // Deletes volume/pod from desired state of world. // Verifies detach/unmount calls are issued. func Test_Run_Positive_VolumeAttachMountUnmountDetach(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Verifies one mount call is made and no unmount calls. // Deletes volume/pod from desired state of world. // Verifies one unmount call is made. // Verifies there are no attach/detach calls made. func Test_Run_Positive_VolumeUnmountControllerAttachEnabled(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Calls Run() // Verifies there are attach/get map paths/setupDevice calls and // no detach/teardownDevice calls. func Test_Run_Positive_VolumeAttachAndMap(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Verifies there are two get map path calls, a setupDevice call // and no teardownDevice call. // Verifies there are no attach/detach calls. func Test_Run_Positive_BlockVolumeMapControllerAttachEnabled(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Calls Run() // Verifies there is one attach call, two get map path calls, // setupDevice call and no detach calls. // Deletes volume/pod from desired state of world. // Verifies one detach/teardownDevice calls are issued. func Test_Run_Positive_BlockVolumeAttachMapUnmapDetach(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Verifies two map path calls are made and no teardownDevice/detach calls. // Deletes volume/pod from desired state of world. // Verifies one teardownDevice call is made. // Verifies there are no attach/detach calls made. func Test_Run_Positive_VolumeUnmapControllerAttachEnabled(t *testing.T) { … } func Test_GenerateMapVolumeFunc_Plugin_Not_Found(t *testing.T) { … } func Test_GenerateUnmapVolumeFunc_Plugin_Not_Found(t *testing.T) { … } func Test_GenerateUnmapDeviceFunc_Plugin_Not_Found(t *testing.T) { … } // Populates desiredStateOfWorld cache with one volume/pod. // Enables controllerAttachDetachEnabled. // Calls Run() // Wait for volume mounted. // Mark volume as fsResizeRequired in ASW. // Verifies volume's fsResizeRequired flag is cleared later. func Test_Run_Positive_VolumeFSResizeControllerAttachEnabled(t *testing.T) { … } func getTestPVC(pvName string, volumeMode *v1.PersistentVolumeMode, specSize, statusSize resource.Quantity) *v1.PersistentVolumeClaim { … } func getTestPV(pvName string, volumeMode *v1.PersistentVolumeMode, pvSize resource.Quantity) *v1.PersistentVolume { … } func getTestPod(claimName string) *v1.Pod { … } func Test_UncertainDeviceGlobalMounts(t *testing.T) { … } func Test_UncertainVolumeMountState(t *testing.T) { … } func waitForUncertainGlobalMount(t *testing.T, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { … } func waitForGlobalMount(t *testing.T, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { … } func waitForUncertainPodMount(t *testing.T, volumeName v1.UniqueVolumeName, podName types.UniquePodName, asw cache.ActualStateOfWorld) { … } func waitForMount( t *testing.T, fakePlugin *volumetesting.FakeVolumePlugin, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { … } func waitForVolumeToExistInASW(t *testing.T, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { … } func waitForDetach( t *testing.T, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { … } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { … } func createTestClient(attachedVolumes ...v1.AttachedVolume) *fake.Clientset { … } func runReconciler(reconciler Reconciler) { … } func createtestClientWithPVPVC(pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim, attachedVolumes ...v1.AttachedVolume) *fake.Clientset { … } func Test_Run_Positive_VolumeMountControllerAttachEnabledRace(t *testing.T) { … } func getFakeNode() *v1.Node { … } func getInlineFakePod(podName, podUUID, outerName, innerName string) *v1.Pod { … } func getReconciler(kubeletDir string, t *testing.T, volumePaths []string, kubeClient *fake.Clientset) (Reconciler, *volumetesting.FakeVolumePlugin) { … } func TestReconcileWithUpdateReconstructedFromAPIServer(t *testing.T) { … }
Codebase Browser
kubernetes