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

type OperationExecutor …

// NewOperationExecutor returns a new instance of 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 { … }