exec

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 3, 2024 License: MIT Imports: 11 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Parse added in v0.3.0 

func Parse(cmd string) ([]string, error)

Parse parses the command string and returns its tokens

func Run 

func Run(cmdStr string) (result string)

Run creates and runs a process and waits for its result (combined stdin,stderr) returned as a string value. This is equivalent to calling Proc.RunProc() followed by Proc.Result().

func RunWithVars added in v0.3.0 

func RunWithVars(cmdStr string, variables *vars.Variables) string

RunWithVars sets session variables and call Run

Types

type CommandBuilder added in v0.1.1 

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

CommandBuilder is a batch command builder that can execute commands using different execution policies (i.e. serial, piped, concurrent)

func Commands added in v0.1.1 

func Commands(cmds ...string) *CommandBuilder

Commands creates a *CommandBuilder used to collect command strings to be executed.

func CommandsWithVars added in v0.3.0 

func CommandsWithVars(variables *vars.Variables, cmds ...string) *CommandBuilder

CommandsWithVars creates a new CommandBuilder and sets session varialbes for it

func (*CommandBuilder) Add added in v0.1.1 

func (cb *CommandBuilder) Add(cmds ...string) *CommandBuilder

Add adds a new command string to the builder

func (*CommandBuilder) Concurr added in v0.2.0 

func (cb *CommandBuilder) Concurr() *CommandResult

Concurr starts all processes concurrently and does not wait for the commands to complete. It is equivalent to Commands(...).WithPolicy(ConcurrentExecPolicy).Start().

func (*CommandBuilder) Pipe added in v0.2.0 

func (cb *CommandBuilder) Pipe() *PipedCommandResult

Pipe executes each command serially chaining the combinedOutput of previous command to the inputPipe of next command.

func (*CommandBuilder) Run added in v0.1.1 

func (cb *CommandBuilder) Run() *CommandResult

Run executes all commands successively and waits for all of the result. The result of each individual command can be accessed from CommandResult.Procs[] after the execution completes. If policy == ExitOnErrPolicy, the execution will stop on the first error encountered, otherwise it will continue. Processes with errors can be accessed from CommandResult.ErrProcs.

func (*CommandBuilder) Start added in v0.1.1 

func (cb *CommandBuilder) Start() *CommandResult

Start starts all processes sequentially by default, or concurrently if ConcurrentExecPolicy is set, and does not wait for the commands to complete. Use CommandResult.Wait to wait for the processes to complete. Then, the result of each command can be accessed from CommandResult.Procs[] or CommandResult.ErrProcs to access failed processses. If policy == ExitOnErrPolicy, the execution will halt on the first error encountered, otherwise it will continue.

func (*CommandBuilder) WithPolicy added in v0.1.1 

func (cb *CommandBuilder) WithPolicy(policyMask CommandPolicy) *CommandBuilder

WithPolicy sets one or more command policy mask values, i.e. (CmdOnErrContinue | CmdExecConcurrent)

func (*CommandBuilder) WithStderr added in v0.4.0 

func (cb *CommandBuilder) WithStderr(err io.Writer) *CommandBuilder

WithStderr sets the standard output err stream for the builder

func (*CommandBuilder) WithStdout added in v0.4.0 

func (cb *CommandBuilder) WithStdout(out io.Writer) *CommandBuilder

WithStdout sets the standard output stream for the builder

type CommandPolicy added in v0.1.1 

type CommandPolicy byte
const (
	ExitOnErrPolicy CommandPolicy = 1 << iota
	ConcurrentExecPolicy
)

type CommandResult added in v0.2.0 

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

CommandResult stores results of executed commands using the CommandBuilder

func (*CommandResult) ErrProcs added in v0.2.0 

func (cr *CommandResult) ErrProcs() []*Proc

ErrProcs returns errored processes

func (*CommandResult) ErrStrings added in v0.3.0 

func (cr *CommandResult) ErrStrings() (errStrings []string)

ErrStrings returns errors as []string

func (*CommandResult) Errs added in v0.3.0 

func (cr *CommandResult) Errs() (errs []error)

Errs returns all errors

func (*CommandResult) Procs added in v0.2.0 

func (cr *CommandResult) Procs() []*Proc

Procs return all executed processes

func (*CommandResult) Wait added in v0.2.0 

func (cr *CommandResult) Wait() *CommandResult

type PipedCommandResult added in v0.2.0 

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

PipedCommandResult stores results of piped commands

func (*PipedCommandResult) ErrProcs added in v0.2.0 

func (cr *PipedCommandResult) ErrProcs() []*Proc

ErrProcs returns errored piped processes

func (*PipedCommandResult) ErrStrings added in v0.3.0 

func (cr *PipedCommandResult) ErrStrings() (errStrings []string)

ErrStrings returns errors as []string

func (*PipedCommandResult) Errs added in v0.3.0 

func (cr *PipedCommandResult) Errs() (errs []error)

Errs returns all errors

func (*PipedCommandResult) LastProc added in v0.2.0 

func (cr *PipedCommandResult) LastProc() *Proc

LastProc executes last executed process

func (*PipedCommandResult) Procs added in v0.2.0 

func (cr *PipedCommandResult) Procs() []*Proc

Procs return all executed processes in pipe

type Proc 

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

Proc stores process info when running a process

func NewProc added in v0.1.1 

func NewProc(cmdStr string) *Proc

NewProc sets up command string to be started as an OS process, however does not start the process. The process must be started using a subsequent call to Proc.StartXXX() or Proc.RunXXX() method.

func NewProcWithVars added in v0.3.0 

func NewProcWithVars(cmdStr string, variables *vars.Variables) *Proc

NewProcWithVars sets up new command string and session variables for a new proc

func RunProc 

func RunProc(cmdStr string) *Proc

RunProc creates, starts, and wait for a new process (with combined stdout/stderr) to complete. Use Proc.Out() to access the command's output as an io.Reader (combining stdout and stderr). Or, use Proc.Result() to access the commands output as a string.

func RunProcWithVars added in v0.3.0 

func RunProcWithVars(cmdStr string, variables *vars.Variables) *Proc

RunProcWithVars sets session variables and calls RunProc

func StartProc 

func StartProc(cmdStr string) *Proc

StartProc creates and starts an OS process (with combined stdout/stderr) and does not wait for it to complete. You must follow this with proc.Wait() to wait for result directly. Then, call proc.Out() or proc.Result() to access the process' result.

func StartProcWithVars added in v0.3.0 

func StartProcWithVars(cmdStr string, variables *vars.Variables) *Proc

StartProcWithVars sets session variables and calls StartProc to create and start a process.

func (*Proc) Command 

func (p *Proc) Command() *osexec.Cmd

Command returns the os/exec.Cmd that started the process

func (*Proc) Err 

func (p *Proc) Err() error

Err returns any execution error

func (*Proc) ExitCode 

func (p *Proc) ExitCode() int

ExitCode returns process exit code

func (*Proc) Exited 

func (p *Proc) Exited() bool

Exited returns true if process exits ok

func (*Proc) GetErrorPipe added in v0.2.0 

func (p *Proc) GetErrorPipe() io.Reader

GetErrorPipe returns a stream where the process error can be read from Deprecated: conflicts with the way the underlying exe.Command works

func (*Proc) GetInputPipe added in v0.2.0 

func (p *Proc) GetInputPipe() io.Writer

GetInputPipe returns a stream where the process input can be written to Deprecated: conflicts with the way the underlying exe.Command works

func (*Proc) GetOutputPipe added in v0.2.0 

func (p *Proc) GetOutputPipe() io.Reader

GetOutputPipe returns a stream where the process output can be read from Deprecated: conflicts with the way the underlying exe.Command works

func (*Proc) ID 

func (p *Proc) ID() int

ID returns process id

func (*Proc) IsSuccess 

func (p *Proc) IsSuccess() bool

IsSuccess returns true if proc exit ok

func (*Proc) Kill 

func (p *Proc) Kill() *Proc

Kill halts the process

func (*Proc) Out 

func (p *Proc) Out() io.Reader

Out returns the combined result (Stdout/Stderr) as a single reader if StartProc, RunProc, or Run package function was used to initiate the process. If Stdout/Stderr was set independently (i.e. with proc.Setstdout(...)) proc.Out will be nil.

NB: Out used to start/wait the process if necessary. However, that behavior has been deprecated. You must ensure the process has been properly initiated and wait for completion prior to calling Out.

func (*Proc) Peek 

func (p *Proc) Peek() *Proc

Peek attempts to read process state information

func (*Proc) Result 

func (p *Proc) Result() string

Result returns the combined stdout and stderr (see Proc.Out()) result as a string value. If there was a previous error in the call chain, this will return the error as a string.

func (*Proc) Run added in v0.2.0 

func (p *Proc) Run() *Proc

Run starts and waits for a process to complete.

func (*Proc) SetStderr added in v0.2.0 

func (p *Proc) SetStderr(out io.Writer)

SetStderr sets a stream where the process can write its errors to

func (*Proc) SetStdin added in v0.2.0 

func (p *Proc) SetStdin(in io.Reader)

SetStdin sets a stream for the process to read its input from

func (*Proc) SetStdout added in v0.2.0 

func (p *Proc) SetStdout(out io.Writer)

SetStdout sets a stream where the process can write its output to

func (*Proc) SetVars added in v0.3.0 

func (p *Proc) SetVars(variables *vars.Variables) *Proc

SetVars sets session variables for Proc

func (*Proc) Start added in v0.1.1 

func (p *Proc) Start() *Proc

Start starts the associated command as an OS process and does not wait for its result. This call should follow a process creation using NewProc. If you don't want to use the internal combined output streams, make sure to configure access to the process' input/output (stdin,stdout,stderr) prior to calling Proc.Start().

func (*Proc) Stderr added in v0.2.0 

func (p *Proc) Stderr() io.Writer

Stderr returns the standard error stream for the process

func (*Proc) Stdin added in v0.2.0 

func (p *Proc) Stdin() io.Reader

Stdin returns the standard input stream for the process

func (*Proc) Stdout added in v0.2.0 

func (p *Proc) Stdout() io.Writer

Stdout returns the standard output stream for the process

func (*Proc) SysTime 

func (p *Proc) SysTime() time.Duration

SysTime returns proc system cpu time

func (*Proc) UserTime 

func (p *Proc) UserTime() time.Duration

UserTime returns proc user cpu time

func (*Proc) Wait 

func (p *Proc) Wait() *Proc

Wait waits for a previously started process to complete. Wait should follow Proc.StartXXX() methods to ensure completion.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.