Documentation
¶
Index ¶
- type Node
- func (n *Node) ConfigureAcceptEnv(jumpbox *Node, nm *NodeManager) error
- func (n *Node) ConfigureInotifyWatches(jumpbox *Node, nm *NodeManager) error
- func (n *Node) CopyFile(jumpbox *Node, nm *NodeManager, src string, dst string) error
- func (n *Node) EnableRootLogin(jumpbox *Node, nm *NodeManager) error
- func (n *Node) HasAcceptEnvConfigured(jumpbox *Node, nm *NodeManager) bool
- func (n *Node) HasCommand(nm *NodeManager, command string) bool
- func (n *Node) HasFile(jumpbox *Node, nm *NodeManager, filePath string) bool
- func (n *Node) HasInotifyWatchesConfigured(jumpbox *Node, nm *NodeManager) bool
- func (n *Node) HasRootLoginEnabled(jumpbox *Node, nm *NodeManager) bool
- func (n *Node) InstallOms(nm *NodeManager) error
- func (n *Node) RunSSHCommand(jumpbox *Node, nm *NodeManager, username string, command string) error
- func (n *Node) WaitForSSH(jumpbox *Node, nm *NodeManager, timeout time.Duration) error
- type NodeManager
- func (n *NodeManager) CopyFile(jumpboxIp string, ip string, username string, src string, dst string) error
- func (nm *NodeManager) EnsureDirectoryExists(jumpboxIp string, ip string, username string, dir string) error
- func (n *NodeManager) GetClient(jumpboxIp string, ip string, username string) (*ssh.Client, error)
- func (n *NodeManager) GetSFTPClient(jumpboxIp string, ip string, username string) (*sftp.Client, error)
- func (n *NodeManager) RunSSHCommand(jumpboxIp string, ip string, username string, command string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Node ¶
type Node struct {
Name string `json:"name"`
ExternalIP string `json:"external_ip"`
InternalIP string `json:"internal_ip"`
}
func (*Node) ConfigureAcceptEnv ¶
func (n *Node) ConfigureAcceptEnv(jumpbox *Node, nm *NodeManager) error
func (*Node) ConfigureInotifyWatches ¶
func (n *Node) ConfigureInotifyWatches(jumpbox *Node, nm *NodeManager) error
func (*Node) EnableRootLogin ¶
func (n *Node) EnableRootLogin(jumpbox *Node, nm *NodeManager) error
func (*Node) HasAcceptEnvConfigured ¶
func (n *Node) HasAcceptEnvConfigured(jumpbox *Node, nm *NodeManager) bool
HasAcceptEnvConfigured checks if AcceptEnv is configured
func (*Node) HasCommand ¶
func (n *Node) HasCommand(nm *NodeManager, command string) bool
func (*Node) HasInotifyWatchesConfigured ¶
func (n *Node) HasInotifyWatchesConfigured(jumpbox *Node, nm *NodeManager) bool
func (*Node) HasRootLoginEnabled ¶
func (n *Node) HasRootLoginEnabled(jumpbox *Node, nm *NodeManager) bool
func (*Node) InstallOms ¶
func (n *Node) InstallOms(nm *NodeManager) error
func (*Node) RunSSHCommand ¶
func (*Node) WaitForSSH ¶
type NodeManager ¶
func (*NodeManager) EnsureDirectoryExists ¶
func (nm *NodeManager) EnsureDirectoryExists(jumpboxIp string, ip string, username string, dir string) error
EnsureDirectoryExists creates the directory on the remote node via SSH if it does not exist.
func (*NodeManager) GetSFTPClient ¶
func (*NodeManager) RunSSHCommand ¶
func (n *NodeManager) RunSSHCommand(jumpboxIp string, ip string, username string, command string) error
RunSSHCommand connects to the node, executes a command and streams the output
Source Files
Click to show internal directories.
Click to hide internal directories.