Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 2018 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 + func ExecScript(ctx context.Context, dir string, env *env.TaskEnv, attrs *syscall.SysProcAttr, ...) ([]byte, int, error) + type ExecCommand struct + Args []string + Cmd string + FSIsolation bool + ResourceLimits bool + TaskKillSignal os.Signal + User string + type Executor interface + Exec func(deadline time.Time, cmd string, args []string) ([]byte, int, 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) + UpdateLogConfig func(logConfig *structs.LogConfig) error + UpdateTask func(task *structs.Task) error + Version func() (*ExecutorVersion, error) + Wait func() (*ProcessState, error) + func NewExecutor(logger *log.Logger) Executor + type ExecutorContext struct + Driver string + LogDir string + PortLowerBound uint + PortUpperBound uint + Task *structs.Task + TaskDir string + TaskEnv *env.TaskEnv + 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 + func (e *UniversalExecutor) Exec(deadline time.Time, name string, args []string) ([]byte, int, 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) 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)
Go to main page