kubernetes/pkg/controller/volume/attachdetach/attach_detach_controller_test.go

const intreePDUniqueNamePrefix …

const csiPDUniqueNamePrefix …

func createADC(t testing.TB, tCtx ktesting.TContext, fakeKubeClient *fake.Clientset,
	informerFactory informers.SharedInformerFactory, plugins []volume.VolumePlugin) *attachDetachController { … }

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

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

func largeClusterClient(t testing.TB, numNodes int) *fake.Clientset { … }

func BenchmarkPopulateActualStateOfWorld(b *testing.B) { … }

func BenchmarkNodeUpdate(b *testing.B) { … }

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

func attachDetachRecoveryTestCase(t *testing.T, extraPods1 []*v1.Pod, extraPods2 []*v1.Pod) { … }

type vaTest …

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

func volumeAttachmentRecoveryTestCase(t *testing.T, tc vaTest) { … }

func verifyExpectedVolumeState(t *testing.T, adc *attachDetachController, tc vaTest) { … }

func verifyAttachDetachCalls(t *testing.T, testPlugin *controllervolumetesting.TestPlugin, tc vaTest) { … }