agent

Documentation

Index

• Variables
• type Client
  • func DefaultClient(*api.Client) (*Client, error)
  • func NewClient(path string) (*Client, error)
  • func (c *Client) Dialer(o *api.Organization) (*Dialer, error)
  • func (c *Client) Establish(slug string) error
  • func (c *Client) Instances(o *api.Organization, app string) (*Instances, error)
  • func (c *Client) Kill() error
  • func (c *Client) Ping() (int, error)
  • func (c *Client) Probe(o *api.Organization) error
• type Dialer
  • func (d *Dialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
• type Instances
• type Server
  • func DefaultServer(ctx *cmdctx.CmdContext) (*Server, error)
  • func NewServer(path string, ctx *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 NewClient

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

func (*Client) Dialer

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

func (*Client) Establish

func (c *Client) Establish(slug string) error

func (*Client) Instances

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

func (*Client) Kill

func (c *Client) Kill() error

func (*Client) Ping

func (c *Client) Ping() (int, error)

func (*Client) Probe

func (c *Client) Probe(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 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, ctx *cmdctx.CmdContext) (*Server, error)

func (*Server) Serve

func (s *Server) Serve()