kubernetes/pkg/volume/plugins_test.go

const testPluginName …

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

type testPlugins …

func (plugin *testPlugins) Init(host VolumeHost) error { … }

func (plugin *testPlugins) GetPluginName() string { … }

func (plugin *testPlugins) GetVolumeName(spec *Spec) (string, error) { … }

func (plugin *testPlugins) CanSupport(spec *Spec) bool { … }

func (plugin *testPlugins) RequiresRemount(spec *Spec) bool { … }

func (plugin *testPlugins) SupportsMountOption() bool { … }

func (plugin *testPlugins) SupportsSELinuxContextMount(spec *Spec) (bool, error) { … }

func (plugin *testPlugins) NewMounter(spec *Spec, podRef *v1.Pod) (Mounter, error) { … }

func (plugin *testPlugins) NewUnmounter(name string, podUID types.UID) (Unmounter, error) { … }

func (plugin *testPlugins) ConstructVolumeSpec(volumeName, mountPath string) (ReconstructedVolume, error) { … }

func newTestPlugin() []VolumePlugin { … }

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

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

// TestVolumePluginMultiThreaded tests FindPluginByName/FindPluginBySpec in a multi-threaded environment.
// If these are called by different threads at the same time, they should still be able to reconcile the plugins
// and return the same results (no missing plugin)
func TestVolumePluginMultiThreaded(t *testing.T) { … }

type fakeProber …

func (prober *fakeProber) Init() error { … }

func (prober *fakeProber) Probe() (events []ProbeEvent, err error) { … }