rexec

Documentation

Index

• func ExecCommandOnInstance(sshConfig *SshConfigDef, ipAddress string, cmd string, isVerbose bool) (l.LogMsg, error)
• func ExecEmbeddedScriptsOnInstance(sshConfig *SshConfigDef, ipAddress string, embeddedScriptPaths []string, ...) (l.LogMsg, error)
• func ExecSshForClient(sshClient *ssh.Client, cmd string) (string, string, error)
• func HarvestAllEmbeddedFilesPaths(curDirPath string, harvestedPathsMap map[string]bool) error
• func NewSshClientConfig(user string, privateKeyOrPath string) (*ssh.ClientConfig, error)
• type ExecResult
  • func ExecSsh(sshConfig *SshConfigDef, ipAddress string, cmd string, ...) ExecResult
  • func ExecSshAndReturnLastLine(sshConfig *SshConfigDef, ipAddress string, cmd string) (string, ExecResult)
  • func (er *ExecResult) ToString() string
• type SshConfigDef
• type TunneledSshClient
  • func NewTunneledSshClient(sshConfig *SshConfigDef, ipAddress string) (*TunneledSshClient, error)
  • func (tsc *TunneledSshClient) Close()

Functions

func ExecCommandOnInstance

func ExecCommandOnInstance(sshConfig *SshConfigDef, ipAddress string, cmd string, isVerbose bool) (l.LogMsg, error)

func ExecEmbeddedScriptsOnInstance

func ExecEmbeddedScriptsOnInstance(sshConfig *SshConfigDef, ipAddress string, embeddedScriptPaths []string, envVars map[string]string, isVerbose bool) (l.LogMsg, error)

func ExecSshForClient

func ExecSshForClient(sshClient *ssh.Client, cmd string) (string, string, error)

Used for file transfer

func HarvestAllEmbeddedFilesPaths

func HarvestAllEmbeddedFilesPaths(curDirPath string, harvestedPathsMap map[string]bool) error

func NewSshClientConfig

func NewSshClientConfig(user string, privateKeyOrPath string) (*ssh.ClientConfig, error)

Types

type ExecResult

type ExecResult struct {
	Cmd     string
	Stdout  string
	Stderr  string
	Elapsed float64
	Error   error
}

func ExecSsh

func ExecSsh(sshConfig *SshConfigDef, ipAddress string, cmd string, envVars map[string]string) ExecResult

func ExecSshAndReturnLastLine

func ExecSshAndReturnLastLine(sshConfig *SshConfigDef, ipAddress string, cmd string) (string, ExecResult)

Used on volume attachment

func (*ExecResult) ToString

func (er *ExecResult) ToString() string

type SshConfigDef

type SshConfigDef struct {
	BastionExternalIpAddressName string `json:"bastion_external_ip_address_name"`
	BastionExternalIp            string `json:"bastion_external_ip_address"` // Output only
	Port                         int    `json:"port"`
	User                         string `json:"user"`
	PrivateKeyOrPath             string `json:"private_key_or_path"`
}

type TunneledSshClient

type TunneledSshClient struct {
	ProxySshClient  *ssh.Client
	TunneledTcpConn net.Conn
	TunneledSshConn ssh.Conn
	SshClient       *ssh.Client
}

func NewTunneledSshClient

func NewTunneledSshClient(sshConfig *SshConfigDef, ipAddress string) (*TunneledSshClient, error)

Our jumphost implementation

func (*TunneledSshClient) Close

func (tsc *TunneledSshClient) Close()