agent

Documentation

Index

• Constants
• func Bicopy(ctx context.Context, c1, c2 io.ReadWriteCloser)
• func ExpandRelativeHomePath(in string) (string, error)
• func New(dialer Dialer, options *Options) io.Closer
• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) DialContext(ctx context.Context, network string, addr string) (net.Conn, error)
  • func (c *Conn) ReconnectingPTY(id string, height, width uint16, command string) (net.Conn, error)
  • func (c *Conn) SSH() (net.Conn, error)
  • func (c *Conn) SSHClient() (*ssh.Client, error)
• type Dialer
• type ListenWireguardPeers
• type Metadata
• type Options
• type ReconnectingPTYRequest
• type UploadWireguardKeys
• type WireguardPublicKeys

Constants

const (
	ProtocolReconnectingPTY = "reconnecting-pty"
	ProtocolSSH             = "ssh"
	ProtocolDial            = "dial"

	// MagicSessionErrorCode indicates that something went wrong with the session, rather than the
	// command just returning a nonzero exit code, and is chosen as an arbitrary, high number
	// unlikely to shadow other exit codes, which are typically 1, 2, 3, etc.
	MagicSessionErrorCode = 229
)

Functions

func Bicopy

func Bicopy(ctx context.Context, c1, c2 io.ReadWriteCloser)

Bicopy copies all of the data between the two connections and will close them after one or both of them are done writing. If the context is canceled, both of the connections will be closed.

func ExpandRelativeHomePath

func ExpandRelativeHomePath(in string) (string, error)

ExpandRelativeHomePath expands the tilde at the beginning of a path to the current user's home directory and returns a full absolute path.

func New

func New(dialer Dialer, options *Options) io.Closer

Types

type Conn

type Conn struct {
	// Negotiator is responsible for exchanging messages.
	Negotiator proto.DRPCPeerBrokerClient

	*peer.Conn
}

Conn wraps a peer connection with helper functions to communicate with the agent.

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) DialContext

func (c *Conn) DialContext(ctx context.Context, network string, addr string) (net.Conn, error)

DialContext dials an arbitrary protocol+address from inside the workspace and proxies it through the provided net.Conn.

func (*Conn) ReconnectingPTY

func (c *Conn) ReconnectingPTY(id string, height, width uint16, command string) (net.Conn, error)

ReconnectingPTY returns a connection serving a TTY that can be reconnected to via ID.

The command is optional and defaults to start a shell.

func (*Conn) SSH

func (c *Conn) SSH() (net.Conn, error)

SSH dials the built-in SSH server.

func (*Conn) SSHClient

func (c *Conn) SSHClient() (*ssh.Client, error)

SSHClient calls SSH to create a client that uses a weak cipher for high throughput.

type Dialer

type Dialer func(ctx context.Context, logger slog.Logger) (Metadata, *peerbroker.Listener, error)

type ListenWireguardPeers

type ListenWireguardPeers func(ctx context.Context, logger slog.Logger) (<-chan peerwg.Handshake, func(), error)

type Metadata

type Metadata struct {
	WireguardAddresses   []netaddr.IPPrefix `json:"addresses"`
	EnvironmentVariables map[string]string  `json:"environment_variables"`
	StartupScript        string             `json:"startup_script"`
	Directory            string             `json:"directory"`
}

type Options

type Options struct {
	EnableWireguard        bool
	UploadWireguardKeys    UploadWireguardKeys
	ListenWireguardPeers   ListenWireguardPeers
	ReconnectingPTYTimeout time.Duration
	EnvironmentVariables   map[string]string
	Logger                 slog.Logger
}

type ReconnectingPTYRequest

type ReconnectingPTYRequest struct {
	Data   string `json:"data"`
	Height uint16 `json:"height"`
	Width  uint16 `json:"width"`
}

ReconnectingPTYRequest is sent from the client to the server to pipe data to a PTY.

type UploadWireguardKeys

type UploadWireguardKeys func(ctx context.Context, keys WireguardPublicKeys) error

type WireguardPublicKeys

type WireguardPublicKeys struct {
	Public key.NodePublic  `json:"public"`
	Disco  key.DiscoPublic `json:"disco"`
}