executor

package

v1.2.6 Latest Latest Go to latest Published: Sep 17, 2020 License: GPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrExecutionimeout = errors.New("execution timeout")
	ErrRestNotOk       = errors.New("rest return non 2XX response")
)

This section is empty.

type DockerExec struct {
	// contains filtered or unexported fields
}

func NewDockerExec(image string, timeout time.Duration) *DockerExec

func (e *DockerExec) Exec(code []byte, arg string, env interface{}) (ExecResult, error)

type ExecResult struct {
	Output  []byte
	Code    uint32
	Version string
}

type Executor interface {
	Exec(exec []byte, arg string, env interface{}) (ExecResult, error)
}

func NewExecutor(executor string) (exec Executor, err error)

NewExecutor returns executor by name and executor URL

type MultiError struct {
	// contains filtered or unexported fields
}

MultiError encapsulates error messages from the underlying executors into one error.

func (e *MultiError) Error() string

Error implements error interface for MultiError by returning all error messages concatenated.

type MultiExec struct {
	// contains filtered or unexported fields
}

MutliExec is a higher-order executor that utlizes the underlying executors to perform Exec.

func NewMultiExec(execs []Executor, strategy string) (*MultiExec, error)

NewMultiExec creates a new MultiExec instance.

func (e *MultiExec) Exec(code []byte, arg string, env interface{}) (ExecResult, error)

Exec implements Executor interface for MultiExec.

type RestExec struct {
	// contains filtered or unexported fields
}

func NewRestExec(url string, timeout time.Duration) *RestExec

func (e *RestExec) Exec(code []byte, arg string, env interface{}) (ExecResult, error)