task_runner

Documentation

Index

• Constants
• type CreateTaskParams
  • func NewCreateTaskParams(action *models.Action, taskGuid, rootFS, domain, logSource string, ...) CreateTaskParams
  • func (c *CreateTaskParams) GetReceptorRequest() receptor.TaskCreateRequest
• type TaskRunner
  • func New(receptorClient receptor.Client, taskExaminer task_examiner.TaskExaminer) TaskRunner

Constants

const (
	AttemptedToCreateLatticeDebugErrorMessage = reserved_app_ids.LatticeDebugLogStreamAppId + " is a reserved app name. It is used internally to stream debug logs for lattice components."
)

Types

type CreateTaskParams

type CreateTaskParams struct {
	// contains filtered or unexported fields
}

func NewCreateTaskParams

func NewCreateTaskParams(action *models.Action, taskGuid, rootFS, domain, logSource string, env map[string]string, egressRules []*models.SecurityGroupRule, memoryMB, cpuWeight, diskMB int) CreateTaskParams

func (*CreateTaskParams) GetReceptorRequest

func (c *CreateTaskParams) GetReceptorRequest() receptor.TaskCreateRequest

type TaskRunner

type TaskRunner interface {
	CreateTask(createTaskParams CreateTaskParams) error
	SubmitTask(submitTaskJson []byte) (string, error)
	DeleteTask(taskGuid string) error
	CancelTask(taskGuid string) error
}

func New

func New(receptorClient receptor.Client, taskExaminer task_examiner.TaskExaminer) TaskRunner