task

Feb 4, 2016

Changes in this version

+ type Task struct

+ Error chan error

+ func NewTask(config *cluster.ContainerConfig, name string, timeout time.Duration) (*Task, error)

+ func (t *Task) Build(slaveID string, offers map[string]*mesosproto.Offer)

+ func (t *Task) GetConfig() *cluster.ContainerConfig

+ func (t *Task) GetContainer() chan *cluster.Container

+ func (t *Task) GetStatus() *mesosproto.TaskStatus

+ func (t *Task) ID() string

+ func (t *Task) Monitor() (bool, []byte, error)

+ func (t *Task) SendStatus(status *mesosproto.TaskStatus)

+ func (t *Task) SetContainer(container *cluster.Container)

+ func (t *Task) Stop()

+ func (t *Task) Stopped() bool

+ type Tasks struct

+ Tasks map[string]*Task

+ func NewTasks(cluster launcher) *Tasks

+ func (t *Tasks) Add(task *Task)

+ func (t *Tasks) Process()

+ func (t *Tasks) Remove(tasks ...*Task)