exec

Documentation

Index

• type ExecutionIntent
  • func NewExecution(via string, script []byte, cwd string) (*ExecutionIntent, error)
  • func (i *ExecutionIntent) AddModifier(mod modifiers.ExecutionModifier) modifiers.ExecutionModifier
  • func (i *ExecutionIntent) Execute() (*ExecutionResult, error)
  • func (i *ExecutionIntent) ImportEnv(env map[string]string)
• type ExecutionResult
• type Process
  • func NewProcess(cmd *exec.Cmd) *Process
  • func (p *Process) Start() (*io.PipeReader, *io.PipeReader, error)
  • func (p *Process) Wait() error
• type StdinReader
  • func NewStdinReader() *StdinReader
  • func (r *StdinReader) Claim() io.ReadCloser
  • func (r *StdinReader) Stop()

Types

type ExecutionIntent

type ExecutionIntent struct {
	Via            string
	Script         []byte
	ReplaceProcess bool
	StartedChan    chan interface{}
	// contains filtered or unexported fields
}

func NewExecution

func NewExecution(via string, script []byte, cwd string) (*ExecutionIntent, error)

func (*ExecutionIntent) AddModifier

func (i *ExecutionIntent) AddModifier(mod modifiers.ExecutionModifier) modifiers.ExecutionModifier

func (*ExecutionIntent) Execute

func (i *ExecutionIntent) Execute() (*ExecutionResult, error)

func (*ExecutionIntent) ImportEnv

func (i *ExecutionIntent) ImportEnv(env map[string]string)

type ExecutionResult

type ExecutionResult struct {
	ScriptPath string
	Output     []byte
	ExitCode   int
	Env        map[string]string
}

type Process

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

func NewProcess

func NewProcess(cmd *exec.Cmd) *Process

func (*Process) Start

func (p *Process) Start() (*io.PipeReader, *io.PipeReader, error)

func (*Process) Wait

func (p *Process) Wait() error

type StdinReader

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

Reading directly from STDIN when executing multiple processes creates issues, as STDIN read is blocking and you can't cancel it. Instead, this is the only place we read from STDIN, and we direct the byte stream to the io.Reader returned by Claim().

func NewStdinReader

func NewStdinReader() *StdinReader

func (*StdinReader) Claim

func (r *StdinReader) Claim() io.ReadCloser

func (*StdinReader) Stop

func (r *StdinReader) Stop()