task

type Handle ¶

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

A Handle is used by the driver plugin to keep track of active tasks.

Handle must be comletetly thread-safe; all operations must go through the lock.

func NewHandle(runner shim.ExecTwo, config *drivers.TaskConfig) (*Handle, time.Time)

func RecreateHandle(runner shim.ExecTwo, config *drivers.TaskConfig, started time.Time) *Handle

func (h *Handle) Block()

func (h *Handle) IsRunning() bool

func (h *Handle) Signal(s string) error

func (h *Handle) Stats() *resources.Utilization

func (h *Handle) Status() *drivers.TaskStatus

func (h *Handle) Stop(signal string, timeout time.Duration) error

type ID ¶

type ID = string

ID is a task ID

type State ¶

type State struct {
	TaskConfig *drivers.TaskConfig
	StartedAt  time.Time
	PID        int
	Cancel     func()
}

State is the runtime state encoded in the handle, returned to the Nomad client. Used to rebuild the task state and handler during recover.

type Store ¶

type Store interface {
	Set(ID, *Handle)
	Get(ID) (*Handle, bool)
	Del(ID)
}

A Store is used to keep track of task handles in memory.

func NewStore() Store