driver

Documentation

Index

• type Driver
• type ExecDriver
  • func NewExecDriver(runner Runner, retrier Retrier, binPath string, logger boshlog.Logger) ExecDriver
  • func (d ExecDriver) Execute(args ...string) (string, error)
  • func (d ExecDriver) ExecuteComplex(args []string, opts ExecuteOpts) (string, error)
  • func (d ExecDriver) IsMissingVMErr(output string) bool
• type ExecuteOpts
• type ExpandingPathRunner
  • func NewExpandingPathRunner(other RawRunner) *ExpandingPathRunner
  • func (r *ExpandingPathRunner) Execute(path string, args ...string) (string, int, error)
  • func (r *ExpandingPathRunner) Get(path string) ([]byte, error)
  • func (r *ExpandingPathRunner) Put(path string, contents []byte) error
  • func (r *ExpandingPathRunner) Upload(srcPath, dstPath string) error
• type LocalRunner
  • func NewLocalRunner(fs boshsys.FileSystem, cmdRunner boshsys.CmdRunner, logger boshlog.Logger) LocalRunner
  • func (r LocalRunner) Execute(path string, args ...string) (string, int, error)
  • func (r LocalRunner) Get(path string) ([]byte, error)
  • func (r LocalRunner) HomeDir() (string, error)
  • func (r LocalRunner) Put(path string, contents []byte) error
  • func (r LocalRunner) Upload(srcPath, dstPath string) error
• type RawRunner
• type Retrier
• type RetrierImpl
  • func (r RetrierImpl) Retry(actionFunc func() error) error
  • func (RetrierImpl) RetryComplex(actionFunc func() error, times int, sleep time.Duration) error
• type RetryableError
• type RetryableErrorImpl
  • func (e RetryableErrorImpl) Error() string
  • func (RetryableErrorImpl) Retryable()
• type Runner
• type SSHRunner
  • func NewSSHRunner(opts SSHRunnerOpts, fs boshsys.FileSystem, logger boshlog.Logger) *SSHRunner
  • func (r *SSHRunner) Execute(path string, args ...string) (string, int, error)
  • func (r *SSHRunner) Get(path string) ([]byte, error)
  • func (r *SSHRunner) HomeDir() (string, error)
  • func (r *SSHRunner) Put(path string, contents []byte) error
  • func (r *SSHRunner) Upload(srcPath, dstPath string) error
• type SSHRunnerOpts

Types

type Driver

type Driver interface {
	Execute(args ...string) (string, error)
	ExecuteComplex(args []string, opts ExecuteOpts) (string, error)
	IsMissingVMErr(output string) bool
}

type ExecDriver

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

func NewExecDriver

func NewExecDriver(runner Runner, retrier Retrier, binPath string, logger boshlog.Logger) ExecDriver

func (ExecDriver) Execute

func (d ExecDriver) Execute(args ...string) (string, error)

func (ExecDriver) ExecuteComplex

func (d ExecDriver) ExecuteComplex(args []string, opts ExecuteOpts) (string, error)

func (ExecDriver) IsMissingVMErr

func (d ExecDriver) IsMissingVMErr(output string) bool

type ExecuteOpts

type ExecuteOpts struct {
	IgnoreNonZeroExitStatus bool
}

type ExpandingPathRunner

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

func NewExpandingPathRunner

func NewExpandingPathRunner(other RawRunner) *ExpandingPathRunner

func (*ExpandingPathRunner) Execute

func (r *ExpandingPathRunner) Execute(path string, args ...string) (string, int, error)

func (*ExpandingPathRunner) Get

func (r *ExpandingPathRunner) Get(path string) ([]byte, error)

func (*ExpandingPathRunner) Put

func (r *ExpandingPathRunner) Put(path string, contents []byte) error

func (*ExpandingPathRunner) Upload

func (r *ExpandingPathRunner) Upload(srcPath, dstPath string) error

type LocalRunner

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

func NewLocalRunner

func NewLocalRunner(fs boshsys.FileSystem, cmdRunner boshsys.CmdRunner, logger boshlog.Logger) LocalRunner

func (LocalRunner) Execute

func (r LocalRunner) Execute(path string, args ...string) (string, int, error)

func (LocalRunner) Get

func (r LocalRunner) Get(path string) ([]byte, error)

func (LocalRunner) HomeDir

func (r LocalRunner) HomeDir() (string, error)

func (LocalRunner) Put

func (r LocalRunner) Put(path string, contents []byte) error

func (LocalRunner) Upload

func (r LocalRunner) Upload(srcPath, dstPath string) error

type RawRunner

type RawRunner interface {
	HomeDir() (string, error)
	Runner
}

type Retrier

type Retrier interface {
	Retry(func() error) error
	RetryComplex(func() error, int, time.Duration) error
}

type RetrierImpl

type RetrierImpl struct{}

func (RetrierImpl) Retry

func (r RetrierImpl) Retry(actionFunc func() error) error

func (RetrierImpl) RetryComplex

func (RetrierImpl) RetryComplex(actionFunc func() error, times int, sleep time.Duration) error

type RetryableError

type RetryableError interface {
	Retryable()
}

type RetryableErrorImpl

type RetryableErrorImpl struct {
	Err error
}

func (RetryableErrorImpl) Error

func (e RetryableErrorImpl) Error() string

func (RetryableErrorImpl) Retryable

func (RetryableErrorImpl) Retryable()

type Runner

type Runner interface {
	Execute(path string, args ...string) (string, int, error)
	Upload(srcDir, dstDir string) error
	Put(path string, contents []byte) error
	Get(path string) ([]byte, error)
}

type SSHRunner

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

func NewSSHRunner

func NewSSHRunner(opts SSHRunnerOpts, fs boshsys.FileSystem, logger boshlog.Logger) *SSHRunner

func (*SSHRunner) Execute

func (r *SSHRunner) Execute(path string, args ...string) (string, int, error)

func (*SSHRunner) Get

func (r *SSHRunner) Get(path string) ([]byte, error)

func (*SSHRunner) HomeDir

func (r *SSHRunner) HomeDir() (string, error)

func (*SSHRunner) Put

func (r *SSHRunner) Put(path string, contents []byte) error

func (*SSHRunner) Upload

func (r *SSHRunner) Upload(srcPath, dstPath string) error

type SSHRunnerOpts

type SSHRunnerOpts struct {
	Host       string
	Username   string
	PrivateKey string
}