executil

Documentation

Index

• type Pipeline
  • func NewPipeline(cmds ...*exec.Cmd) (*Pipeline, error)
  • func (p *Pipeline) Append(cmd *exec.Cmd) (err error)
  • func (p *Pipeline) Execute() (out []byte, err error)

Types

type Pipeline

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

Pipeline represents a series of commands linked by their stdout and stdin

func NewPipeline

func NewPipeline(cmds ...*exec.Cmd) (*Pipeline, error)

NewPipeline create a new pipeline, optionally with commands

func (*Pipeline) Append

func (p *Pipeline) Append(cmd *exec.Cmd) (err error)

Append adds a new command to the tail end of the pipeline, connecting its stdin to the stdout of the previous tail

func (*Pipeline) Execute

func (p *Pipeline) Execute() (out []byte, err error)

Execute starts each command in the pipeline and waits for their completion in reverse order, capturing the stdout of the last command