executor

Documentation

Index

• Variables
• type ExecResult
• type Executor
  • func NewExecutor(executor string) (exec Executor, err error)
• type MultiError
  • func (e *MultiError) Error() string
• type MultiExec
  • func NewMultiExec(execs []Executor, strategy string) (*MultiExec, error)
  • func (e *MultiExec) Exec(code []byte, arg string, env interface{}) (ExecResult, error)
• type RestExec
  • func NewRestExec(url string, timeout time.Duration) *RestExec
  • func (e *RestExec) Exec(code []byte, arg string, env interface{}) (ExecResult, error)

Variables

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

Types

type ExecResult

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

type Executor

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

func NewExecutor

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

NewExecutor returns executor by name and executor URL

type MultiError

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

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

func (*MultiError) Error

func (e *MultiError) Error() string

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

type MultiExec

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

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

func NewMultiExec

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

NewMultiExec creates a new MultiExec instance.

func (*MultiExec) Exec

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

Exec implements Executor interface for MultiExec.

type RestExec

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

func NewRestExec

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

func (*RestExec) Exec

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