ssh

Documentation

Index

• Constants
• func GetBasicSession(s *sshProviderClient) (*ssh.Session, *ssh.Client, error)
• func NewSSHProviderClient(privateKey string, passPhrase string, machineSSHConfig v1alpha1.SSHConfig) *sshProviderClient
• func PublicKeyFile(privateKey string, passPhrase string) (ssh.AuthMethod, error)
• func SSHAgent() ssh.AuthMethod
• type SSHProviderClientInterface

Constants

const (
	// TODO: This is to quickly work around a customer problem. We should
	// implement a connection pool instead.
	SshTimeoutSeconds    = 600
	SshTimeout           = time.Duration(SshTimeoutSeconds) * time.Second
	GetKubeconfigCommand = "cat /etc/kubernetes/admin.conf"
)

Functions

func GetBasicSession

func GetBasicSession(s *sshProviderClient) (*ssh.Session, *ssh.Client, error)

func NewSSHProviderClient

func NewSSHProviderClient(privateKey string, passPhrase string, machineSSHConfig v1alpha1.SSHConfig) *sshProviderClient

func PublicKeyFile

func PublicKeyFile(privateKey string, passPhrase string) (ssh.AuthMethod, error)

func SSHAgent

func SSHAgent() ssh.AuthMethod

this should allow local use of clusterctl to access remote cluster as long as your socket has the private key added to the agent.

Types

type SSHProviderClientInterface

type SSHProviderClientInterface interface {
	ProcessCMD(cmd string) error
	ProcessCMDWithOutput(cmd string) ([]byte, error)
	WritePublicKeys(machineSSHConfig v1alpha1.SSHConfig) error
	DeletePublicKeys(machineSSHConfig v1alpha1.SSHConfig) error
	GetKubeConfig() (string, error)
	GetKubeConfigBytes() ([]byte, error)
}