dcos

Documentation

Index

• type Task
  • func NewTask(data *TaskData, podName string) *Task
  • func (task *Task) GetMongoAddr() (*db.Addr, error)
  • func (task *Task) GetMongoReplsetName() (string, error)
  • func (task *Task) HasState() bool
  • func (task *Task) IsRunning() bool
  • func (task *Task) IsTaskType(taskType pod.TaskType) bool
  • func (task *Task) IsUpdating() bool
  • func (task *Task) Name() string
  • func (task *Task) Service() string
  • func (task *Task) State() pod.TaskState
• type TaskCommand
• type TaskCommandEnvironment
• type TaskCommandEnvironmentVariable
• type TaskData
• type TaskInfo
• type TaskState
  • func (s TaskState) String() string
• type TaskStatus

Types

type Task

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

func NewTask

func NewTask(data *TaskData, podName string) *Task

func (*Task) GetMongoAddr

func (task *Task) GetMongoAddr() (*db.Addr, error)

func (*Task) GetMongoReplsetName

func (task *Task) GetMongoReplsetName() (string, error)

func (*Task) HasState

func (task *Task) HasState() bool

func (*Task) IsRunning

func (task *Task) IsRunning() bool

func (*Task) IsTaskType

func (task *Task) IsTaskType(taskType pod.TaskType) bool

func (*Task) IsUpdating

func (task *Task) IsUpdating() bool

TODO: implement .IsUpdating() on DC/OS

func (*Task) Name

func (task *Task) Name() string

func (*Task) Service

func (task *Task) Service() string

func (*Task) State

func (task *Task) State() pod.TaskState

type TaskCommand

type TaskCommand struct {
	Environment *TaskCommandEnvironment `json:"environment"`
	Value       string                  `json:"value"`
}

type TaskCommandEnvironment

type TaskCommandEnvironment struct {
	Variables []*TaskCommandEnvironmentVariable `json:"variables"`
}

type TaskCommandEnvironmentVariable

type TaskCommandEnvironmentVariable struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type TaskData

type TaskData struct {
	Info   *TaskInfo   `json:"info"`
	Status *TaskStatus `json:"status"`
}

type TaskInfo

type TaskInfo struct {
	Name    string       `json:"name"`
	Command *TaskCommand `json:"command"`
}

type TaskState

type TaskState string

var (
	TaskStateError    TaskState = "TASK_ERROR"
	TaskStateFailed   TaskState = "TASK_FAILED"
	TaskStateFinished TaskState = "TASK_FINISHED"
	TaskStateKilled   TaskState = "TASK_KILLED"
	TaskStateLost     TaskState = "TASK_LOST"
	TaskStateRunning  TaskState = "TASK_RUNNING"
	TaskStateUnknown  TaskState = "UNKNOWN"
)

func (TaskState) String

func (s TaskState) String() string

type TaskStatus

type TaskStatus struct {
	State *TaskState `json:"state"`
}