connector

type SSHConnector ¶

type SSHConnector struct {
	// contains filtered or unexported fields
}

SSHConnector establishes a connection to the machine API through an SSH tunnel to the machine.

func NewSSHConnector(cfg *SSHConnectorConfig) *SSHConnector

func NewSSHConnectorFromClient(client *ssh.Client) *SSHConnector

func (c *SSHConnector) Close() error

func (c *SSHConnector) Connect(ctx context.Context) (*grpc.ClientConn, error)

type SSHConnectorConfig ¶

type SSHConnectorConfig struct {
	User    string
	Host    string
	Port    int
	KeyPath string

	SockPath string
}

type TCPConnector ¶

type TCPConnector struct {
	// contains filtered or unexported fields
}

TCPConnector establishes a connection to the machine API through a direct TCP connection to an API endpoint.

func NewTCPConnector(apiAddr netip.AddrPort) *TCPConnector

func (c *TCPConnector) Close() error

func (c *TCPConnector) Connect(_ context.Context) (*grpc.ClientConn, error)

type WireGuardConnector ¶

type WireGuardConnector struct {
	// contains filtered or unexported fields
}

WireGuardConnector establishes a connection to the cluster API through a WireGuard tunnel to one of the cluster machines.

func NewWireGuardConnector(user *client.User, machines []config.MachineConnection) *WireGuardConnector

func (c *WireGuardConnector) Close() error

func (c *WireGuardConnector) Connect(ctx context.Context) (*grpc.ClientConn, error)