executor

Documentation

Index

• type Executor
• type LocalExecutor
  • func NewLocalExecutor() *LocalExecutor
  • func (le *LocalExecutor) Close() error
  • func (le *LocalExecutor) GetName() string
  • func (le *LocalExecutor) GetTags() []string
  • func (le *LocalExecutor) InitCommand(workdir string, cmd []string, envVars map[string]string, tags []string) (*bufio.Reader, error)
  • func (le *LocalExecutor) Start() error
  • func (le *LocalExecutor) Wait() (bool, error)
• type NodeSSHExecutor
  • func NewNodeSSHExecutor(nd *node.Node) (*NodeSSHExecutor, error)
  • func (ne *NodeSSHExecutor) Close() error
  • func (ne *NodeSSHExecutor) GetName() string
  • func (ne *NodeSSHExecutor) GetTags() []string
  • func (ne *NodeSSHExecutor) InitCommand(workdir string, cmd []string, envVars map[string]string, tags []string) (*bufio.Reader, error)
  • func (ne *NodeSSHExecutor) Start() error
  • func (ne *NodeSSHExecutor) Wait() (bool, error)

Types

type Executor

type Executor interface {
	GetName() string
	InitCommand(string, []string, map[string]string, []string) (*bufio.Reader, error)
	Start() error
	Wait() (bool, error)
	Close() error
	GetTags() []string
}

type LocalExecutor

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

func NewLocalExecutor

func NewLocalExecutor() *LocalExecutor

func (*LocalExecutor) Close

func (le *LocalExecutor) Close() error

func (*LocalExecutor) GetName

func (le *LocalExecutor) GetName() string

func (*LocalExecutor) GetTags

func (le *LocalExecutor) GetTags() []string

func (*LocalExecutor) InitCommand

func (le *LocalExecutor) InitCommand(workdir string, cmd []string, envVars map[string]string, tags []string) (*bufio.Reader, error)

func (*LocalExecutor) Start

func (le *LocalExecutor) Start() error

func (*LocalExecutor) Wait

func (le *LocalExecutor) Wait() (bool, error)

type NodeSSHExecutor

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

func NewNodeSSHExecutor

func NewNodeSSHExecutor(nd *node.Node) (*NodeSSHExecutor, error)

func (*NodeSSHExecutor) Close

func (ne *NodeSSHExecutor) Close() error

func (*NodeSSHExecutor) GetName

func (ne *NodeSSHExecutor) GetName() string

func (*NodeSSHExecutor) GetTags

func (ne *NodeSSHExecutor) GetTags() []string

func (*NodeSSHExecutor) InitCommand

func (ne *NodeSSHExecutor) InitCommand(workdir string, cmd []string, envVars map[string]string, tags []string) (*bufio.Reader, error)

func (*NodeSSHExecutor) Start

func (ne *NodeSSHExecutor) Start() error

func (*NodeSSHExecutor) Wait

func (ne *NodeSSHExecutor) Wait() (bool, error)