kubernetes/pkg/kubelet/pluginmanager/operationexecutor/operation_executor_test.go

const numPluginsToRegister …

const numPluginsToUnregister …

var _ …

var socketDir …

func init() { … }

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

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

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

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

type fakeOperationGenerator …

func newFakeOperationGenerator(ch chan interface{ … }

func (fopg *fakeOperationGenerator) GenerateRegisterPluginFunc(
	socketPath string,
	pluginUUID types.UID,
	pluginHandlers map[string]cache.PluginHandler,
	actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error { … }

func (fopg *fakeOperationGenerator) GenerateUnregisterPluginFunc(
	pluginInfo cache.PluginInfo,
	actualStateOfWorldUpdater ActualStateOfWorldUpdater) func() error { … }

func isOperationRunSerially(ch <-chan interface{ … }

func isOperationRunConcurrently(ch <-chan interface{ … }

func setup() (chan interface{ … }

// This function starts by writing to ch and blocks on the quit channel
// until it is closed by the currently running test
func startOperationAndBlock(ch chan<- interface{ … }