exec

Documentation

Index

• type ErrorDetails
  • func ParseError(scripts *scripts.ScriptManager, stdout string) *ErrorDetails
  • func (e *ErrorDetails) String(colors aurora.Aurora) string
• type ErrorSource
• 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 ErrorDetails

type ErrorDetails struct {
	Error       string
	ErrorSource *ErrorSource
}

func ParseError

func ParseError(scripts *scripts.ScriptManager, stdout string) *ErrorDetails

func (*ErrorDetails) String

func (e *ErrorDetails) String(colors aurora.Aurora) string

type ErrorSource

type ErrorSource struct {
	Source []byte
	Line   int
}

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 {
	Scripts  *scripts.ScriptManager
	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()