kubernetes/pkg/volume/flexvolume/probe_test.go

const pluginDir …

const driverName …

const errorDriverName …

func assertPathSuffix(t *testing.T, dir1 string, dir2 string) { … }

// Probes a driver installed before prober initialization.
func TestProberExistingDriverBeforeInit(t *testing.T) { … }

// Probes newly added drivers after prober is running.
func TestProberAddRemoveDriver(t *testing.T) { … }

// Tests the behavior when no drivers exist in the plugin directory.
func TestEmptyPluginDir(t *testing.T) { … }

// Issue an event to remove plugindir. New directory should still be watched.
func TestRemovePluginDir(t *testing.T) { … }

// Issue an event to remove plugindir. New directory should still be watched.
func TestNestedDriverDir(t *testing.T) { … }

// Issue multiple events and probe multiple times.
func TestProberMultipleEvents(t *testing.T) { … }

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

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

// TestProberMultiThreaded tests the code path of many callers calling FindPluginBySpec/FindPluginByName
// which then calls refreshProbedPlugins which then calls prober.Probe() and ensures that the prober is thread safe
func TestProberMultiThreaded(t *testing.T) { … }

// Installs a mock driver (an empty file) in the mock fs.
func installDriver(driverName string, fs utilfs.Filesystem) { … }

// Initializes mocks, installs a single driver in the mock fs, then initializes prober.
func initTestEnvironment(t *testing.T) (
	driverPath string,
	fs utilfs.Filesystem,
	watcher *fakeWatcher,
	prober volume.DynamicPluginProber) { … }

type fakePluginFactory …

var _ …

func (m fakePluginFactory) NewFlexVolumePlugin(_, driverName string, _ exec.Interface) (volume.VolumePlugin, error) { … }