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{ … }
func startOperationAndBlock(ch chan<- interface{ … }