executable

Documentation

Index

• Constants
• type BasicTask
  • func (t *BasicTask) Kill() error
  • func (t *BasicTask) Launch() error
  • func (t *BasicTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition
  • func (t *BasicTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)
• type CommitResponse
• type ControllableTask
  • func (t *ControllableTask) Kill() error
  • func (t *ControllableTask) Launch() error
  • func (t *ControllableTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition
  • func (t *ControllableTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)
• type HookTask
  • func (t *HookTask) Kill() error
  • func (t *HookTask) Launch() error
  • func (t *HookTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition
  • func (t *HookTask) Trigger() error
  • func (t *HookTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)
• type SendDeviceEventFunc
• type SendMessageFunc
• type SendStatusFunc
• type Task
  • func NewTask(taskInfo mesos.TaskInfo, sendStatusFunc SendStatusFunc, ...) Task

Constants

const (
	DONE_TIMEOUT            = 1 * time.Second
	SIGTERM_TIMEOUT         = 2 * time.Second
	SIGINT_TIMEOUT          = 3 * time.Second
	KILL_TRANSITION_TIMEOUT = 5 * time.Second // to be on the safe side, readout might need up to 5s to go from RUNNING to DONE
	TRANSITION_TIMEOUT      = 10 * time.Second
)

Types

type BasicTask

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

func (*BasicTask) Kill

func (t *BasicTask) Kill() error

func (*BasicTask) Launch

func (t *BasicTask) Launch() error

func (*BasicTask) Transition

func (t *BasicTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition

func (*BasicTask) UnmarshalTransition

func (t *BasicTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)

type CommitResponse

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

type ControllableTask

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

func (*ControllableTask) Kill

func (t *ControllableTask) Kill() error

func (*ControllableTask) Launch

func (t *ControllableTask) Launch() error

func (*ControllableTask) Transition

func (t *ControllableTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition

func (*ControllableTask) UnmarshalTransition

func (t *ControllableTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)

type HookTask

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

func (*HookTask) Kill

func (t *HookTask) Kill() error

func (*HookTask) Launch

func (t *HookTask) Launch() error

func (*HookTask) Transition

func (t *HookTask) Transition(cmd *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition

func (*HookTask) Trigger

func (t *HookTask) Trigger() error

func (*HookTask) UnmarshalTransition

func (t *HookTask) UnmarshalTransition(data []byte) (cmd *executorcmd.ExecutorCommand_Transition, err error)

type SendDeviceEventFunc

type SendDeviceEventFunc func(envId uid.ID, event event.DeviceEvent)

type SendMessageFunc

type SendMessageFunc func(message []byte)

type SendStatusFunc

type SendStatusFunc func(envId uid.ID, state mesos.TaskState, message string)

type Task

type Task interface {
	Launch() error
	Kill() error
	Transition(transition *executorcmd.ExecutorCommand_Transition) *controlcommands.MesosCommandResponse_Transition
	UnmarshalTransition([]byte) (*executorcmd.ExecutorCommand_Transition, error)
}

func NewTask

func NewTask(taskInfo mesos.TaskInfo, sendStatusFunc SendStatusFunc, sendDeviceEventFunc SendDeviceEventFunc, sendMessageFunc SendMessageFunc) Task