executor

Documentation

Index

• type Manager
  • func GetManager() *Manager
  • func (m *Manager) Get(name types.Name) (types.TaskExecutor, error)
  • func (m *Manager) Initialize(cfgs []apistructs.ClusterInfo) error

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) Initialize

func (m *Manager) Initialize(cfgs []apistructs.ClusterInfo) error