taskrunner

Jul 30, 2019

Changes in this version

type TaskRunner

+ func (tr *TaskRunner) MarkFailedDead(reason string)

Jun 5, 2019

Changes in this version

type Config

+ ServersContactedCh chan struct{}

type DriverHandle

+ func (h *DriverHandle) ExecStreaming(ctx context.Context, command []string, tty bool, stream drivers.ExecTaskStream) error

type TaskRunner

+ func (tr *TaskRunner) DriverCapabilities() (*drivers.Capabilities, error)

+ func (tr *TaskRunner) TaskExecHandler() drivermanager.TaskExecHandler

Apr 9, 2019

Changes in this version

+ const HookNameDevices

+ const TaskDirHookIsDoneDataKey

+ var ErrTaskNotRunning = errors.New(errTaskNotRunning)

+ func NewHookError(err error, taskEvent *structs.TaskEvent) error

+ type Config struct

+ Alloc *structs.Allocation

+ ClientConfig *config.Config

+ Consul consul.ConsulServiceAPI

+ DeviceManager devicemanager.Manager

+ DeviceStatsReporter cinterfaces.DeviceStatsReporter

+ DriverManager drivermanager.Manager

+ Logger log.Logger

+ StateDB cstate.StateDB

+ StateUpdater interfaces.TaskStateHandler

+ Task *structs.Task

+ TaskDir *allocdir.TaskDir

+ Vault vaultclient.VaultClient

+ type DriverHandle struct

+ func NewDriverHandle(driver drivers.DriverPlugin, taskID string, task *structs.Task, ...) *DriverHandle

+ func (h *DriverHandle) Exec(timeout time.Duration, cmd string, args []string) ([]byte, int, error)

+ func (h *DriverHandle) ID() string

+ func (h *DriverHandle) Kill() error

+ func (h *DriverHandle) Network() *drivers.DriverNetwork

+ func (h *DriverHandle) Signal(s string) error

+ func (h *DriverHandle) Stats(ctx context.Context, interval time.Duration) (<-chan *cstructs.TaskResourceUsage, error)

+ func (h *DriverHandle) Update(task *structs.Task) error

+ func (h *DriverHandle) WaitCh(ctx context.Context) (<-chan *drivers.ExitResult, error)

+ type LazyHandle struct

+ func NewLazyHandle(shutdownCtx context.Context, fn retrieveHandleFn, logger log.Logger) *LazyHandle

+ func (l *LazyHandle) Exec(timeout time.Duration, cmd string, args []string) ([]byte, int, error)

+ func (l *LazyHandle) Stats(ctx context.Context, interval time.Duration) (<-chan *cstructs.TaskResourceUsage, error)

+ type StatsUpdater interface

+ UpdateStats func(*cstructs.TaskResourceUsage)

+ type TaskRunner struct

+ func NewTaskRunner(config *Config) (*TaskRunner, error)

+ func (tr *TaskRunner) Alloc() *structs.Allocation

+ func (tr *TaskRunner) AppendEvent(event *structs.TaskEvent)

+ func (tr *TaskRunner) EmitEvent(event *structs.TaskEvent)

+ func (tr *TaskRunner) IsLeader() bool

+ func (tr *TaskRunner) Kill(ctx context.Context, event *structs.TaskEvent) error

+ func (tr *TaskRunner) LatestResourceUsage() *cstructs.TaskResourceUsage

+ func (tr *TaskRunner) Restart(ctx context.Context, event *structs.TaskEvent, failure bool) error

+ func (tr *TaskRunner) Restore() error

+ func (tr *TaskRunner) Run()

+ func (tr *TaskRunner) Shutdown()

+ func (tr *TaskRunner) Signal(event *structs.TaskEvent, s string) error

+ func (tr *TaskRunner) Task() *structs.Task

+ func (tr *TaskRunner) TaskState() *structs.TaskState

+ func (tr *TaskRunner) Update(update *structs.Allocation)

+ func (tr *TaskRunner) UpdateState(state string, event *structs.TaskEvent)

+ func (tr *TaskRunner) UpdateStats(ru *cstructs.TaskResourceUsage)

+ func (tr *TaskRunner) WaitCh() <-chan struct{}