kubernetes/pkg/volume/csi/csi_plugin_test.go

const volumeHostType …

const kubeletVolumeHostType …

const attachDetachVolumeHostType …

func newTestPlugin(t *testing.T, client *fakeclient.Clientset) (*csiPlugin, string) { … }

func newTestPluginWithAttachDetachVolumeHost(t *testing.T, client *fakeclient.Clientset) (*csiPlugin, string) { … }

// create a plugin mgr to load plugins and setup a fake client
func newTestPluginWithVolumeHost(t *testing.T, client *fakeclient.Clientset, hostType int) (*csiPlugin, string) { … }

func registerFakePlugin(pluginName, endpoint string, versions []string, t *testing.T) { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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