runner

Documentation

Index

• type Input
• type Output
• type Runner
• type Subprocess
  • func NewSubprocess(logger *logger.Autopilot) *Subprocess
  • func (s *Subprocess) Execute(input *Input, timeout time.Duration) (*Output, error)

Types

type Input

type Input struct {
	Cmd     string
	Args    []string
	Env     map[string]string
	Secrets map[string]string
	WorkDir string
}

type Output

type Output struct {
	Data     []map[string]interface{} `json:"data"`
	WorkDir  string
	Logs     []string `json:"logs"`
	ErrLogs  []string `json:"err_logs"`
	ExitCode int      `json:"exit_code"`
}

type Runner

type Runner interface {
	Execute(input *Input, timeout time.Duration) (*Output, error)
}

type Subprocess

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

func NewSubprocess

func NewSubprocess(logger *logger.Autopilot) *Subprocess

func (*Subprocess) Execute

func (s *Subprocess) Execute(input *Input, timeout time.Duration) (*Output, error)