actionexecutor

Documentation

Index

• func GetExecutorInfo() interface{}
• type Manager
  • func GetManager() *Manager
  • func (m *Manager) Get(name types.Name) (types.ActionExecutor, error)
  • func (m *Manager) GetActionExecutorKindByName(name string) (string, error)
  • func (m *Manager) GetByKind(kind types.Kind) []types.ActionExecutor
  • func (m *Manager) GetCreateFnByKind(kind types.Kind) (types.CreateFn, error)
  • func (m *Manager) GetKindByExecutorName(name types.Name) (types.Kind, bool)
  • func (m *Manager) Initialize(ctx context.Context, cfgs chan spec.ActionExecutorConfig, ...) error
  • func (m *Manager) ListExecutors() []types.ActionExecutor
  • func (m *Manager) ListenAndPatchK8sExecutor(ctx context.Context)

Functions

func GetExecutorInfo

func GetExecutorInfo() interface{}

Types

type Manager

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Manager is an executor manager, it holds the all executor instances.

func GetManager

func GetManager() *Manager

func (*Manager) Get

func (m *Manager) Get(name types.Name) (types.ActionExecutor, error)

Get returns the executor with name.

func (*Manager) GetActionExecutorKindByName

func (m *Manager) GetActionExecutorKindByName(name string) (string, error)

GetActionExecutorKindByName return executor Kind, e.g. MEMORY

func (*Manager) GetByKind

func (m *Manager) GetByKind(kind types.Kind) []types.ActionExecutor

GetByKind returns the executor instances with specify kind.

func (*Manager) GetCreateFnByKind

func (m *Manager) GetCreateFnByKind(kind types.Kind) (types.CreateFn, error)

func (*Manager) GetKindByExecutorName

func (m *Manager) GetKindByExecutorName(name types.Name) (types.Kind, bool)

func (*Manager) Initialize

func (m *Manager) Initialize(ctx context.Context, cfgs chan spec.ActionExecutorConfig, clusterInfo clusterinfo.Interface) error

func (*Manager) ListExecutors

func (m *Manager) ListExecutors() []types.ActionExecutor

ListExecutors returns the all executor instances.

func (*Manager) ListenAndPatchK8sExecutor

func (m *Manager) ListenAndPatchK8sExecutor(ctx context.Context)