runner

Documentation

Index

• func GetExitCode(err error) (int, error)
• type Runner
  • func NewRunner(owner, basedir string) *Runner
  • func (r *Runner) ExecuteCommand(command string, args ...string)
• type SignalsForwarder
  • func NewSignalsForwarder(signals []os.Signal, c *exec.Cmd, cmdChannel chan error) SignalsForwarder
  • func (s *SignalsForwarder) Close() error

Functions

func GetExitCode

func GetExitCode(err error) (int, error)

GetExitCode attempts to unrap an exit code into something that gives more context into why the runner exited

Types

type Runner

type Runner struct {
	Owner      string
	ID         int64
	BaseDir    string
	StdoutFile string
	StderrFile string
	Program    string
	Args       []string
	FinChan    chan bool
	Output     chan string
	Errors     chan error
	EnvVars    map[string]string
}

Runner is a command executor with streaming output over channels

func NewRunner

func NewRunner(owner, basedir string) *Runner

NewRunner returns a new empty runner

func (*Runner) ExecuteCommand

func (r *Runner) ExecuteCommand(command string, args ...string)

ExecuteCommand executes the command in a sub process, streaming output over the Runner's output channels.

type SignalsForwarder

type SignalsForwarder chan os.Signal

SignalsForwarder passes signals between the current program and the runners sub processes

func NewSignalsForwarder

func NewSignalsForwarder(signals []os.Signal, c *exec.Cmd, cmdChannel chan error) SignalsForwarder

NewSignalsForwarder creates a new signals forwarder for the runner

func (*SignalsForwarder) Close

func (s *SignalsForwarder) Close() error

Close closes the SignalForwardering goroutine