ssh

Documentation

Index

• func NewRunner(r *eventline.Runner) eventline.RunnerBehaviour
• func NewRunnerParameters() eventline.RunnerParameters
• func RunnerDef() *eventline.RunnerDef
• type Runner
  • func (r *Runner) DirPath() string
  • func (r *Runner) ExecuteStep(ctx context.Context, se *eventline.StepExecution, step *eventline.Step, ...) error
  • func (r *Runner) Init(ctx context.Context) error
  • func (r *Runner) Terminate()
• type RunnerCfg
  • func (cfg *RunnerCfg) ValidateJSON(v *ejson.Validator)
• type RunnerParameters
  • func (r *RunnerParameters) ValidateJSON(v *ejson.Validator)

Functions

func NewRunner

func NewRunner(r *eventline.Runner) eventline.RunnerBehaviour

func NewRunnerParameters

func NewRunnerParameters() eventline.RunnerParameters

func RunnerDef

func RunnerDef() *eventline.RunnerDef

Types

type Runner

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

func (*Runner) DirPath

func (r *Runner) DirPath() string

func (*Runner) ExecuteStep

func (r *Runner) ExecuteStep(ctx context.Context, se *eventline.StepExecution, step *eventline.Step, stdout, stderr io.WriteCloser) error

func (*Runner) Init

func (r *Runner) Init(ctx context.Context) error

func (*Runner) Terminate

func (r *Runner) Terminate()

type RunnerCfg

type RunnerCfg struct {
	RootDirectory string `json:"root_directory"`
}

func (*RunnerCfg) ValidateJSON

func (cfg *RunnerCfg) ValidateJSON(v *ejson.Validator)

type RunnerParameters

type RunnerParameters struct {
	Host             string `json:"host"`
	Port             int    `json:"port"`
	User             string `json:"user"`
	HostKey          []byte `json:"host_key,omitempty"`
	HostKeyAlgorithm string `json:"host_key_algorithm,omitempty"`
}

func (*RunnerParameters) ValidateJSON

func (r *RunnerParameters) ValidateJSON(v *ejson.Validator)