executor

package

Go to main page

Versions in this module

v0

v0.8.4-rc1

Jun 1, 2018

v0.7.0

Nov 1, 2017

Changes in this version

+ func ExecScript(ctx context.Context, dir string, env *env.TaskEnv, attrs *syscall.SysProcAttr, ...) ([]byte, int, error)

type Executor

+ Exec func(deadline time.Time, cmd string, args []string) ([]byte, int, error)

type UniversalExecutor

+ func (e *UniversalExecutor) Exec(deadline time.Time, name string, args []string) ([]byte, int, error)

v0.7.0-rc1

Oct 19, 2017

v0.5.5

Mar 14, 2017

Changes in this version

+ var ExecutorBasicMeasuredCpuStats = []string

+ var ExecutorBasicMeasuredMemStats = []string

+ var ExecutorCgroupMeasuredCpuStats = []string — linux/amd64

+ var ExecutorCgroupMeasuredMemStats = []string — linux/amd64

+ func ClientCleanup(ic *dstructs.IsolationConfig, pid int) error

+ func DestroyCgroup(groups *cgroupConfig.Cgroup, cgPaths map[string]string, executorPid int) error — linux/amd64

+ type ConsulContext struct

+ ConsulConfig *config.ConsulConfig

+ ContainerID string

+ DockerEndpoint string

+ TLSCa string

+ TLSCert string

+ TLSKey string

+ type DockerScriptCheck struct

+ func (d *DockerScriptCheck) ID() string

+ func (d *DockerScriptCheck) Interval() time.Duration

+ func (d *DockerScriptCheck) Run() *cstructs.CheckResult

+ func (d *DockerScriptCheck) Timeout() time.Duration

+ type ExecCommand struct

+ Args []string

+ Cmd string

+ FSIsolation bool

+ ResourceLimits bool

+ User string

+ type ExecScriptCheck struct

+ FSIsolation bool

+ func (e *ExecScriptCheck) ID() string

+ func (e *ExecScriptCheck) Interval() time.Duration

+ func (e *ExecScriptCheck) Run() *cstructs.CheckResult

+ func (e *ExecScriptCheck) Timeout() time.Duration

type Executor

+ DeregisterServices func() error

+ Exit func() error

+ LaunchCmd func(command *ExecCommand) (*ProcessState, error)

+ LaunchSyslogServer func() (*SyslogServerState, error)

+ SetContext func(ctx *ExecutorContext) error

+ ShutDown func() error

+ Signal func(s os.Signal) error

+ Stats func() (*cstructs.TaskResourceUsage, error)

+ SyncServices func(ctx *ConsulContext) error

+ UpdateLogConfig func(logConfig *structs.LogConfig) error

+ UpdateTask func(task *structs.Task) error

+ Version func() (*ExecutorVersion, error)

+ type ExecutorContext struct

+ AllocID string

+ Driver string

+ LogDir string

+ PortLowerBound uint

+ PortUpperBound uint

+ Task *structs.Task

+ TaskDir string

+ TaskEnv *env.TaskEnvironment

+ type ExecutorVersion struct

+ Version string

+ func (v *ExecutorVersion) GoString() string

+ type ProcessState struct

+ ExitCode int

+ IsolationConfig *dstructs.IsolationConfig

+ Pid int

+ Signal int

+ Time time.Time

+ type SyslogServerState struct

+ Addr string

+ IsolationConfig *dstructs.IsolationConfig

+ type UniversalExecutor struct — linux/amd64

+ func (e *UniversalExecutor) DeregisterServices() error

+ func (e *UniversalExecutor) Exit() error

+ func (e *UniversalExecutor) LaunchCmd(command *ExecCommand) (*ProcessState, error)

+ func (e *UniversalExecutor) LaunchSyslogServer() (*SyslogServerState, error)

+ func (e *UniversalExecutor) SetContext(ctx *ExecutorContext) error

+ func (e *UniversalExecutor) ShutDown() error

+ func (e *UniversalExecutor) Signal(s os.Signal) error

+ func (e *UniversalExecutor) Stats() (*cstructs.TaskResourceUsage, error)

+ func (e *UniversalExecutor) SyncServices(ctx *ConsulContext) error

+ func (e *UniversalExecutor) UpdateLogConfig(logConfig *structs.LogConfig) error

+ func (e *UniversalExecutor) UpdateTask(task *structs.Task) error

+ func (e *UniversalExecutor) Version() (*ExecutorVersion, error)

+ func (e *UniversalExecutor) Wait() (*ProcessState, error)

v0.5.1-rc1

Dec 6, 2016

v0.4.0-rc2

Jun 22, 2016

v0.2.2

Dec 11, 2015

Changes in this version

+ func SetCommand(e Executor, name string, args []string)

+ type BasicExecutor struct

+ func (e *BasicExecutor) Command() *exec.Cmd

+ func (e *BasicExecutor) ConfigureTaskDir(taskName string, alloc *allocdir.AllocDir) error

+ func (e *BasicExecutor) ForceStop() error

+ func (e *BasicExecutor) ID() (string, error)

+ func (e *BasicExecutor) Limit(resources *structs.Resources) error

+ func (e *BasicExecutor) Open(id string) error

+ func (e *BasicExecutor) Shutdown() error

+ func (e *BasicExecutor) Start() error

+ func (e *BasicExecutor) Wait() *cstructs.WaitResult

+ type ExecLinuxID struct — linux/amd64

+ Groups *cgroupConfig.Cgroup

+ Spawn *spawn.Spawner

+ TaskDir string

+ type Executor interface

+ Command func() *exec.Cmd

+ ConfigureTaskDir func(taskName string, alloc *allocdir.AllocDir) error

+ ForceStop func() error

+ ID func() (string, error)

+ Limit func(*structs.Resources) error

+ Open func(string) error

+ Shutdown func() error

+ Start func() error

+ Wait func() *cstructs.WaitResult

+ func Command(name string, args ...string) Executor

+ func NewBasicExecutor() Executor

+ func NewExecutor() Executor

+ func NewLinuxExecutor() Executor

+ func OpenId(id string) (Executor, error)

+ type LinuxExecutor struct — linux/amd64

+ func (e *LinuxExecutor) Command() *exec.Cmd

+ func (e *LinuxExecutor) ConfigureTaskDir(taskName string, alloc *allocdir.AllocDir) error

+ func (e *LinuxExecutor) ForceStop() error

+ func (e *LinuxExecutor) ID() (string, error)

+ func (e *LinuxExecutor) Limit(resources *structs.Resources) error

+ func (e *LinuxExecutor) Open(id string) error

+ func (e *LinuxExecutor) Shutdown() error

+ func (e *LinuxExecutor) Start() error

+ func (e *LinuxExecutor) Wait() *cstructs.WaitResult

+ type UniversalExecutor struct — darwin/amd64, js/wasm, windows/amd64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL