kubernetes/pkg/kubelet/pluginmanager/plugin_manager_test.go

var socketDir …

var supportedVersions …

type fakePluginHandler …

func newFakePluginHandler() *fakePluginHandler { … }

// ValidatePlugin is a fake method
func (f *fakePluginHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error { … }

// RegisterPlugin is a fake method
func (f *fakePluginHandler) RegisterPlugin(pluginName, endpoint string, versions []string, pluginClientTimeout *time.Duration) error { … }

// DeRegisterPlugin is a fake method
func (f *fakePluginHandler) DeRegisterPlugin(pluginName string) { … }

func (f *fakePluginHandler) Reset() { … }

func init() { … }

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

func waitForRegistration(t *testing.T, fakePluginHandler *fakePluginHandler, pluginName string) { … }

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

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

func newTestPluginManager(sockDir string) PluginManager { … }