type OperationExecutor …
func NewOperationExecutor(
operationGenerator OperationGenerator) OperationExecutor { … }
type ActualStateOfWorldUpdater …
type operationExecutor …
var _ …
func (oe *operationExecutor) IsOperationPending(socketPath string) bool { … }
func (oe *operationExecutor) RegisterPlugin(
socketPath string,
pluginUUID types.UID,
pluginHandlers map[string]cache.PluginHandler,
actualStateOfWorld ActualStateOfWorldUpdater) error { … }
func (oe *operationExecutor) UnregisterPlugin(
pluginInfo cache.PluginInfo,
actualStateOfWorld ActualStateOfWorldUpdater) error { … }