remote

Documentation

Index

• func GetFileInRemotePath(scid string, conf config.SSHConfig, remotePath string, localPath string) error
• func GetFilesInRemoteDir(scid string, conf config.SSHConfig, remoteDir string, localDir string) error
• func GetFtpClient(client *ssh.Client) (*sftp.Client, error)
• func GetNebulaComponentStatus(ipAddress string, port int) ([]string, error)
• func GetNebulaConfigs(ipAddress string, port int) ([]string, error)
• func GetNebulaMetrics(ipAddress string, port int) ([]string, error)
• type ExecuteResult
• type SSHClient
  • func GetSSHClient(scid string, conf config.SSHConfig) (*SSHClient, error)
  • func (c *SSHClient) Execute(cmd string) (ExecuteResult, bool)
  • func (c *SSHClient) ExecuteAsync(cmd string, ch chan<- ExecuteResult)

Functions

func GetFileInRemotePath

func GetFileInRemotePath(scid string, conf config.SSHConfig, remotePath string, localPath string) error

TODO

func GetFilesInRemoteDir

func GetFilesInRemoteDir(scid string, conf config.SSHConfig, remoteDir string, localDir string) error

func GetFtpClient

func GetFtpClient(client *ssh.Client) (*sftp.Client, error)

func GetNebulaComponentStatus

func GetNebulaComponentStatus(ipAddress string, port int) ([]string, error)

func GetNebulaConfigs

func GetNebulaConfigs(ipAddress string, port int) ([]string, error)

func GetNebulaMetrics

func GetNebulaMetrics(ipAddress string, port int) ([]string, error)

Types

type ExecuteResult

type ExecuteResult struct {
	CMD     string
	Err     error
	StdOut  []byte
	StdErr  []byte
	Latency time.Duration
}

type SSHClient

type SSHClient struct {
	*ssh.Client
}

func GetSSHClient

func GetSSHClient(scid string, conf config.SSHConfig) (*SSHClient, error)

func (*SSHClient) Execute

func (c *SSHClient) Execute(cmd string) (ExecuteResult, bool)

func (*SSHClient) ExecuteAsync

func (c *SSHClient) ExecuteAsync(cmd string, ch chan<- ExecuteResult)