executor

Documentation

Index

• func GetExecutorInfo() interface{}
• type Manager
  • func GetManager() *Manager
  • func (m *Manager) Get(name types.Name) (types.TaskExecutor, error)
  • func (m *Manager) GetCluster(clusterName string) (apistructs.ClusterInfo, error)
  • func (m *Manager) Initialize() error
  • func (m *Manager) TryGetExecutor(name types.Name, cluster apistructs.ClusterInfo) (bool, types.TaskExecutor, error)

Functions

func GetExecutorInfo

func GetExecutorInfo() interface{}

Types

type Manager

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

Manager for scheduler task executor

func GetManager

func GetManager() *Manager

func (*Manager) Get

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

func (*Manager) GetCluster

func (m *Manager) GetCluster(clusterName string) (apistructs.ClusterInfo, error)

func (*Manager) Initialize

func (m *Manager) Initialize() error

func (*Manager) TryGetExecutor

func (m *Manager) TryGetExecutor(name types.Name, cluster apistructs.ClusterInfo) (bool, types.TaskExecutor, error)

TryGetExecutor if can`t get executor, manager try to make new executor by cluster info and return new executor