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) {}