runtime

Documentation

Index

• Constants
• type Runtime
  • func NewRuntime(nodeInfo *core.NodeInfo, profile *config.Profile) *Runtime
  • func (r *Runtime) CreateExecutor(taskInfo *core.TaskConfig) (executor.Executor, error)
  • func (r *Runtime) GetTaskIDs() []string
  • func (r *Runtime) QueryAllExecutorConfig() map[string]core.TaskConfig
  • func (r *Runtime) RemoveExecutor(taskId string) error
  • func (r *Runtime) Start() error
  • func (r *Runtime) StartExecutor(taskId string) error
  • func (r *Runtime) Stop() error
  • func (r *Runtime) StopExecutor(taskId string) error

Constants

const (
	RuntimeStatus_Init   = 0
	RuntimeStatus_Run    = 1
	RuntimeStatus_Stop   = 2
	TaskHeader_StartTime = "Rockman.Runtime.StartTime"
)

Types

type Runtime

type Runtime struct {
	TaskService *task.TaskService
	Executors   map[string]executor.Executor

	Status int
	// contains filtered or unexported fields
}

func NewRuntime

func NewRuntime(nodeInfo *core.NodeInfo, profile *config.Profile) *Runtime

func (*Runtime) CreateExecutor

func (r *Runtime) CreateExecutor(taskInfo *core.TaskConfig) (executor.Executor, error)

CreateExecutor create new executor and register to task service now support http\shell\go.so

func (*Runtime) GetTaskIDs

func (r *Runtime) GetTaskIDs() []string

func (*Runtime) QueryAllExecutorConfig

func (r *Runtime) QueryAllExecutorConfig() map[string]core.TaskConfig

func (*Runtime) RemoveExecutor

func (r *Runtime) RemoveExecutor(taskId string) error

func (*Runtime) Start

func (r *Runtime) Start() error

func (*Runtime) StartExecutor

func (r *Runtime) StartExecutor(taskId string) error

func (*Runtime) Stop

func (r *Runtime) Stop() error

func (*Runtime) StopExecutor

func (r *Runtime) StopExecutor(taskId string) error