exec

Documentation

Index

• Constants
• Variables
• func CheckFilepathExists(ctx context.Context, cl spec.Channel, filepath string) bool
• func ConvertOutputToResponse(ctx context.Context, output string, err error, defaultResponse *spec.Response) *spec.Response
• func Destroy(ctx context.Context, c spec.Channel, action string) *spec.Response
• func Hierarchy(root string) func() ([]cgroups.Subsystem, error)
• func NewSSHExecutor() spec.Executor
• func PidPath(pid int) cgroups.Path
• type SSHClient
  • func (c SSHClient) RunCommand(command string) ([]byte, error)
  • func (c SSHClient) RunCommandWithResponse(ctx context.Context, cmd string) (*spec.Response, bool)
• type SSHExecutor
  • func (e *SSHExecutor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response
  • func (*SSHExecutor) Name() string
  • func (e *SSHExecutor) SetChannel(channel spec.Channel)

Constants

const (
	DefaultInstallPath = "/opt/chaosblade"
	BladeBin           = "blade"
	DefaultSSHPort     = 22
	BladeReleaseURL    = "https://chaosblade.oss-cn-hangzhou.aliyuncs.com/agent/github/%s/chaosblade-%s-linux-amd64.tar.gz"
)

Variables

var BladeRelease = &spec.ExpFlag{
	Name:     "blade-release",
	Desc:     "Blade release package，use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

var ChannelFlag = &spec.ExpFlag{
	Name:     "channel",
	Desc:     "Select the channel for execution, and you can now select SSH",
	NoArgs:   false,
	Required: false,
}

support ssh channel flags

var InstallPath = &spec.ExpFlag{
	Name:     "install-path",
	Desc:     "install path default /opt/chaosblade，use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

var OverrideBladeRelease = &spec.ExpFlag{
	Name:     "override-blade-release",
	Desc:     "Override blade release，use this flag when the channel is ssh",
	NoArgs:   true,
	Required: false,
}

var SSHHostFlag = &spec.ExpFlag{
	Name:     "ssh-host",
	Desc:     "Use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

var SSHKeyFlag = &spec.ExpFlag{
	Name:     "ssh-key",
	Desc:     "Use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

var SSHKeyPassphraseFlag = &spec.ExpFlag{
	Name:     "ssh-key-passphrase",
	Desc:     "Use this flag when the channel is ssh",
	NoArgs:   true,
	Required: false,
}

var SSHPortFlag = &spec.ExpFlag{
	Name:     "ssh-port",
	Desc:     "Use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

var SSHUserFlag = &spec.ExpFlag{
	Name:     "ssh-user",
	Desc:     "Use this flag when the channel is ssh",
	NoArgs:   false,
	Required: false,
}

Functions

func CheckFilepathExists

func CheckFilepathExists(ctx context.Context, cl spec.Channel, filepath string) bool

func ConvertOutputToResponse

func ConvertOutputToResponse(ctx context.Context, output string, err error, defaultResponse *spec.Response) *spec.Response

func Destroy

func Destroy(ctx context.Context, c spec.Channel, action string) *spec.Response

stop hang process

func Hierarchy

func Hierarchy(root string) func() ([]cgroups.Subsystem, error)

func NewSSHExecutor

func NewSSHExecutor() spec.Executor

func PidPath

func PidPath(pid int) cgroups.Path

Types

type SSHClient

type SSHClient struct {
	Host     string
	Username string
	Key      string

	Password string
	Port     int
	// contains filtered or unexported fields
}

func (SSHClient) RunCommand

func (c SSHClient) RunCommand(command string) ([]byte, error)

func (SSHClient) RunCommandWithResponse

func (c SSHClient) RunCommandWithResponse(ctx context.Context, cmd string) (*spec.Response, bool)

type SSHExecutor

type SSHExecutor struct {
	spec.Executor
}

func (*SSHExecutor) Exec

func (e *SSHExecutor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response

func (*SSHExecutor) Name

func (*SSHExecutor) Name() string

func (*SSHExecutor) SetChannel

func (e *SSHExecutor) SetChannel(channel spec.Channel)