streamexec

Documentation

Index

• type Options
• type Params
• type Result
  • func (r Result) Error() string
  • func (r Result) Structured() string
  • func (r Result) Text(debug bool) string
• type StreamExec
  • func New(inputstream io.ReadCloser, outputstream io.WriteCloser, ...) *StreamExec
  • func (s *StreamExec) Run() error

Types

type Options

type Options struct {
	ErrorLog           string
	OutputLog          string
	IncomingBufferSize int
	Concurrency        int
	ContinueOnErr      bool
	DryRun             bool
	DebugMode          bool
	Params             Params
}

type Params

type Params struct {
	ExecString string
	Retries    int
}

type Result

type Result struct {
	Envvars   []string `json:",omitempty"`
	Params    Params   `json:",omitempty"`
	Stderr    string   `json:",omitempty"`
	Stdout    string   `json:",omitempty"`
	ExitCode  int      `json:",omitempty"`
	Succeeded bool
}

func (Result) Error

func (r Result) Error() string

func (Result) Structured

func (r Result) Structured() string

func (Result) Text

func (r Result) Text(debug bool) string

type StreamExec

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

func New

func New(inputstream io.ReadCloser, outputstream io.WriteCloser, errStream io.WriteCloser, o Options) *StreamExec

func (*StreamExec) Run

func (s *StreamExec) Run() error