network

Documentation

Index

• Constants
• func IsClosed(err error) bool
• type Dialer
• type RetryDialer
  • func NewRetryDialer() *RetryDialer
  • func (d *RetryDialer) Dial(network, address string) (c net.Conn, err error)
• type SSHAgent
  • func NewSSHAgent(dialer Dialer) (*SSHAgent, error)
  • func (a *SSHAgent) Close() error
  • func (a *SSHAgent) NewClient(host string) (*ssh.Client, error)

Constants

const (
	// DefaultTimeout sets the default timeout for RetryDialer.
	DefaultTimeout = 5 * time.Second

	// DefaultKeepAlive sets the default keepalive for RetryDialer.
	DefaultKeepAlive = 30 * time.Second

	// DefaultRetries sets the default number of retries for RetryDialer.
	DefaultRetries = 7
)

Functions

func IsClosed

func IsClosed(err error) bool

IsClosed detects if an error is due to a closed network connection, working around bug https://github.com/golang/go/issues/4373

Types

type Dialer

type Dialer interface {
	Dial(network, address string) (net.Conn, error)
}

Dialer is an interface for anything compatible with net.Dialer

type RetryDialer

type RetryDialer struct {
	net.Dialer
	Retries int
}

RetryDialer is intended to timeout quickly and retry connecting instead of just failing. Particularly useful for waiting on a booting machine.

func NewRetryDialer

func NewRetryDialer() *RetryDialer

NewRetryDialer initializes a RetryDialer with reasonable default settings.

func (*RetryDialer) Dial

func (d *RetryDialer) Dial(network, address string) (c net.Conn, err error)

Dial connects to a remote address, retrying on failure.

type SSHAgent

type SSHAgent struct {
	agent.Agent
	Dialer
	User   string
	Socket string
	// contains filtered or unexported fields
}

SSHAgent can manage keys, updates cloud config, and loves ponies. The embedded dialer is used for establishing new SSH connections.

func NewSSHAgent

func NewSSHAgent(dialer Dialer) (*SSHAgent, error)

NewSSHAgent constructs a new SSHAgent using dialer to create ssh connections.

func (*SSHAgent) Close

func (a *SSHAgent) Close() error

Close closes the unix socket of the agent.

func (*SSHAgent) NewClient

func (a *SSHAgent) NewClient(host string) (*ssh.Client, error)

NewClient connects to the given host via SSH, the client will support agent forwarding but it must also be enabled per-session.