kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_test.go

var supportedVersions …

func init() { … }

func initTempDir(t *testing.T) string { … }

func waitForRegistration(
	t *testing.T,
	socketPath string,
	dsw cache.DesiredStateOfWorld) { … }

func waitForUnregistration(
	t *testing.T,
	socketPath string,
	dsw cache.DesiredStateOfWorld) { … }

func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { … }

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

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

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

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

func newWatcher(t *testing.T, socketDir string, desiredStateOfWorldCache cache.DesiredStateOfWorld, stopCh <-chan struct{ … }