runner

Documentation

Index

• Variables
• func ExecCmd(system, dir, cmd string, stdOutWriter, stdErrWriter io.Writer, ...) error
• type CompositeNotReadyError
  • func NewCompositeNotReadyError(previousError string) *CompositeNotReadyError
  • func (cnre *CompositeNotReadyError) Error() string
  • func (cnre *CompositeNotReadyError) PreviousError() string

Variables

var ErrAirbyteAlreadyTerminated = errors.New("Airbyte Runner has been already terminated. You can use it only once.")

var ErrNotReady = errors.New("not ready")

Functions

func ExecCmd

func ExecCmd(system, dir, cmd string, stdOutWriter, stdErrWriter io.Writer, timeout time.Duration, args ...string) error

ExecCmd executes command with args and uses stdOutWriter and stdErrWriter to pipe the result runs separate goroutine for timeout control

Types

type CompositeNotReadyError

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

func NewCompositeNotReadyError

func NewCompositeNotReadyError(previousError string) *CompositeNotReadyError

func (*CompositeNotReadyError) Error

func (cnre *CompositeNotReadyError) Error() string

Error returns not ready error

func (*CompositeNotReadyError) PreviousError

func (cnre *CompositeNotReadyError) PreviousError() string

PreviousError returns previous error