executor

Documentation

Overview

Package executor xxx

Index

• Constants
• type Executor
  • func NewExecutor(cxt context.Context) Executor

Constants

const (
	// ReportTaskStatusPeriod xxx
	// report task status time
	ReportTaskStatusPeriod = 30 // seconds
)

Types

type Executor

type Executor interface {
	// LaunchTaskgroup xxx
	// launch taskgroup
	LaunchTaskgroup(*mesos.TaskGroupInfo)

	// Shutdown xxx
	// shut down
	Shutdown()

	// RegisterCallbackFunc xxx
	// register callback function
	RegisterCallbackFunc(types.CallbackFuncType, interface{})

	// GetExecutorStatus xxx
	// Get Executor status
	GetExecutorStatus() types.ExecutorStatus

	// ReloadTasks xxx
	// reload tasks, exec reloadCmd
	ReloadTasks() error

	// RestartTasks xxx
	// restart tasks, exec restartCmd
	RestartTasks() error

	AckTaskStatusMessage(taskId string, uuid []byte)
}

Executor xxx

func NewExecutor

func NewExecutor(cxt context.Context) Executor

NewExecutor xxx