const reconcilerLoopSleepDuration …
const waitForAttachTimeout …
const nodeName …
const kubeletPodsDir …
const testOperationBackOffDuration …
const reconcilerSyncWaitDuration …
func hasAddedPods() bool { … }
func Test_Run_Positive_DoNothing(t *testing.T) { … }
func Test_Run_Positive_VolumeAttachAndMount(t *testing.T) { … }
func Test_Run_Positive_VolumeAttachAndMountMigrationEnabled(t *testing.T) { … }
func Test_Run_Positive_VolumeMountControllerAttachEnabled(t *testing.T) { … }
func Test_Run_Negative_VolumeMountControllerAttachEnabled(t *testing.T) { … }
func Test_Run_Positive_VolumeAttachMountUnmountDetach(t *testing.T) { … }
func Test_Run_Positive_VolumeUnmountControllerAttachEnabled(t *testing.T) { … }
func Test_Run_Positive_VolumeAttachAndMap(t *testing.T) { … }
func Test_Run_Positive_BlockVolumeMapControllerAttachEnabled(t *testing.T) { … }
func Test_Run_Positive_BlockVolumeAttachMapUnmapDetach(t *testing.T) { … }
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) { … }
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) { … }