executor

package
v1.27.0-alpha.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

Types

type Executor

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

	//shut down
	Shutdown()

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

	//Get Executor status
	GetExecutorStatus() types.ExecutorStatus

	//reload tasks, exec reloadCmd
	ReloadTasks() error

	//restart tasks, exec restartCmd
	RestartTasks() error

	AckTaskStatusMessage(taskId string, uuid []byte)
}

func NewExecutor

func NewExecutor(cxt context.Context) Executor

NewExecutor

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL