agent

Documentation

Index

• Variables
• type Client
  • func DefaultClient(*api.Client) (*Client, error)
  • func Establish(ctx context.Context, apiClient *api.Client) (*Client, error)
  • func NewClient(path string) (*Client, error)
  • func StartDaemon(ctx context.Context, api *api.Client, command string) (*Client, error)
  • func (c *Client) Dialer(ctx context.Context, o *api.Organization) (*Dialer, error)
  • func (c *Client) Establish(ctx context.Context, slug string) error
  • func (c *Client) Instances(ctx context.Context, o *api.Organization, app string) (*Instances, error)
  • func (c *Client) Kill(ctx context.Context) error
  • func (c *Client) Ping(ctx context.Context) (int, error)
  • func (c *Client) Probe(ctx context.Context, o *api.Organization) error
  • func (c *Client) WaitForTunnel(ctx context.Context, o *api.Organization) error
• type Dialer
  • func (d *Dialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
• type ErrProbeFailed
  • func (e *ErrProbeFailed) Error() string
• type Instances
• type Server
  • func DefaultServer(ctx *cmdctx.CmdContext) (*Server, error)
  • func NewServer(path string, cmdCtx *cmdctx.CmdContext) (*Server, error)
  • func (s *Server) Serve()

Variables

var (
	ErrCantBind = errors.New("can't bind agent socket")
)

var (
	ErrUnreachable = errors.New("can't connect to agent")
)

Types

type Client

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

func DefaultClient

func DefaultClient(*api.Client) (*Client, error)

func Establish

func Establish(ctx context.Context, apiClient *api.Client) (*Client, error)

/ Establish starts the daemon if necessary and returns a client

func NewClient

func NewClient(path string) (*Client, error)

func StartDaemon

func StartDaemon(ctx context.Context, api *api.Client, command string) (*Client, error)

func (*Client) Dialer

func (c *Client) Dialer(ctx context.Context, o *api.Organization) (*Dialer, error)

func (*Client) Establish

func (c *Client) Establish(ctx context.Context, slug string) error

func (*Client) Instances

func (c *Client) Instances(ctx context.Context, o *api.Organization, app string) (*Instances, error)

func (*Client) Kill

func (c *Client) Kill(ctx context.Context) error

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) (int, error)

func (*Client) Probe

func (c *Client) Probe(ctx context.Context, o *api.Organization) error

func (*Client) WaitForTunnel

func (c *Client) WaitForTunnel(ctx context.Context, o *api.Organization) error

type Dialer

type Dialer struct {
	Org     *api.Organization
	Timeout time.Duration
	// contains filtered or unexported fields
}

func (*Dialer) DialContext

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

type ErrProbeFailed

type ErrProbeFailed struct {
	Msg string
}

func (*ErrProbeFailed) Error

func (e *ErrProbeFailed) Error() string

type Instances

type Instances struct {
	Labels    []string
	Addresses []string
}

type Server

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

func DefaultServer

func DefaultServer(ctx *cmdctx.CmdContext) (*Server, error)

func NewServer

func NewServer(path string, cmdCtx *cmdctx.CmdContext) (*Server, error)

func (*Server) Serve

func (s *Server) Serve()