Documentation ¶
Index ¶
Constants ¶
View Source
const (
AttemptedToCreateLatticeDebugErrorMessage = reserved_app_ids.LatticeDebugLogStreamAppId + " is a reserved app name. It is used internally to stream debug logs for lattice components."
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Directories ¶
Path | Synopsis |
---|---|
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.