executor

package

v1.4.0 Latest Latest Go to latest Published: Nov 16, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func GetExecutorInfo() interface{}

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

Manager for scheduler task executor

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)

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