Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v1

v1.6.112

Aug 13, 2023

v1.6.111

Aug 13, 2023

v1.6.110

Aug 13, 2023

v1.6.109

Aug 13, 2023

v1.6.108

Aug 12, 2023

Changes in this version

+ const ExecutorDefaultMaxPort

+ const ExecutorDefaultMinPort

+ const ExecutorVersionLatest

+ const ExecutorVersionPre0_9

+ const IsolationModeHost

+ const IsolationModePrivate

+ var ExecutorBasicMeasuredCpuStats = []string

+ var ExecutorBasicMeasuredMemStats = []string

+ var ExecutorCgroupMeasuredCpuStats = []string — linux/amd64

+ var ExecutorCgroupV1MeasuredMemStats = []string — linux/amd64

+ var ExecutorCgroupV2MeasuredMemStats = []string — 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 IsolationMode(plugin, task string) string

+ func SupportedCaps(allowNetRaw bool) []string

+ type ExecCommand struct

+ Args []string

+ BasicProcessCgroup bool

+ Capabilities []string

+ Cmd string

+ Devices []*drivers.DeviceConfig

+ Env []string

+ ModeIPC string

+ ModePID string

+ Mounts []*drivers.MountConfig

+ NetworkIsolation *drivers.NetworkIsolationSpec

+ NoPivotRoot bool

+ 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)

+ ExecStreaming func(ctx context.Context, cmd []string, tty bool, stream drivers.ExecTaskStream) 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)

+ 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) ExecStreaming(ctx context.Context, cmd []string, tty bool, stream drivers.ExecTaskStream) 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) ExecStreaming(ctx context.Context, command []string, tty bool, stream drivers.ExecTaskStream) 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)