executor

May 28, 2020

Changes in this version

type ExecCommand

+ NoPivotRoot bool

Apr 1, 2020

Changes in this version

type ExecCommand

+ NetworkIsolation *drivers.NetworkIsolationSpec

Jun 5, 2019

Changes in this version

type Executor

+ ExecStreaming func(ctx context.Context, cmd []string, tty bool, stream drivers.ExecTaskStream) error

type LibcontainerExecutor — linux/amd64

+ func (l *LibcontainerExecutor) ExecStreaming(ctx context.Context, cmd []string, tty bool, stream drivers.ExecTaskStream) error

type UniversalExecutor

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

Apr 9, 2019

Changes in this version

+ const ExecutorDefaultMaxPort

+ const ExecutorDefaultMinPort

+ const ExecutorVersionLatest

+ const ExecutorVersionPre0_9

+ var ExecutorBasicMeasuredCpuStats = []string

+ var ExecutorBasicMeasuredMemStats = []string

+ var ExecutorCgroupMeasuredCpuStats = []string — linux/amd64

+ var ExecutorCgroupMeasuredMemStats = []string — linux/amd64

+ func DestroyCgroup(groups *lconfigs.Cgroup, executorPid int) error — linux/amd64

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

+ func GetPluginMap(logger hclog.Logger, fsIsolation bool) map[string]plugin.Plugin

+ func GetPre09PluginMap(logger hclog.Logger, fsIsolation bool) map[string]plugin.Plugin

+ func JoinRootCgroup(subsystems []string) error — linux/amd64

+ type ExecCommand struct

+ Args []string

+ BasicProcessCgroup bool

+ Cmd string

+ Devices []*drivers.DeviceConfig

+ Env []string

+ Mounts []*drivers.MountConfig

+ ResourceLimits bool

+ Resources *drivers.Resources

+ StderrPath string

+ StdoutPath string

+ TaskDir string

+ User string

+ func (c *ExecCommand) Close()

+ func (c *ExecCommand) GetWriters() (stdout io.WriteCloser, stderr io.WriteCloser)

+ func (c *ExecCommand) SetWriters(out io.WriteCloser, err io.WriteCloser)

+ func (c *ExecCommand) Stderr() (io.WriteCloser, error)

+ func (c *ExecCommand) Stdout() (io.WriteCloser, error)

+ type Executor interface

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

+ Launch func(launchCmd *ExecCommand) (*ProcessState, error)

+ Shutdown func(signal string, gracePeriod time.Duration) error

+ Signal func(os.Signal) error

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

+ UpdateResources func(*drivers.Resources) error

+ Version func() (*ExecutorVersion, error)

+ Wait func(ctx context.Context) (*ProcessState, error)

+ func CreateExecutor(logger hclog.Logger, driverConfig *base.ClientDriverConfig, ...) (Executor, *plugin.Client, error)

+ func NewExecutor(logger hclog.Logger) Executor

+ func NewExecutorWithIsolation(logger hclog.Logger) Executor

+ func ReattachToExecutor(reattachConfig *plugin.ReattachConfig, logger hclog.Logger) (Executor, *plugin.Client, error)

+ func ReattachToPre09Executor(reattachConfig *plugin.ReattachConfig, logger hclog.Logger) (Executor, *plugin.Client, error)

+ type ExecutorConfig struct

+ FSIsolation bool

+ LogFile string

+ LogLevel string

+ type ExecutorPlugin struct

+ func (p *ExecutorPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *ExecutorPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type ExecutorVersion struct

+ Version string

+ func (v *ExecutorVersion) GoString() string

+ type LibcontainerExecutor struct — linux/amd64

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

+ func (l *LibcontainerExecutor) Launch(command *ExecCommand) (*ProcessState, error)

+ func (l *LibcontainerExecutor) Shutdown(signal string, grace time.Duration) error

+ func (l *LibcontainerExecutor) Signal(s os.Signal) error

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

+ func (l *LibcontainerExecutor) UpdateResources(resources *drivers.Resources) error

+ func (l *LibcontainerExecutor) Version() (*ExecutorVersion, error)

+ func (l *LibcontainerExecutor) Wait(ctx context.Context) (*ProcessState, error)

+ type PluginReattachConfig struct

+ AddrName string

+ AddrNet string

+ Pid int

+ func NewPluginReattachConfig(c *plugin.ReattachConfig) *PluginReattachConfig

+ func (c *PluginReattachConfig) PluginConfig() *plugin.ReattachConfig

+ type ProcessState struct

+ ExitCode int

+ Pid int

+ Signal int

+ Time time.Time

+ type UniversalExecutor struct

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

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

+ func (e *UniversalExecutor) Shutdown(signal string, grace time.Duration) error

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

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

+ func (e *UniversalExecutor) UpdateResources(resources *drivers.Resources) error

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

+ func (e *UniversalExecutor) Wait(ctx context.Context) (*ProcessState, error)