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