agent

package
v0.0.272-pre-5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 29, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrCantBind          = errors.New("can't bind agent socket")
	ErrTunnelUnavailable = errors.New("tunnel unavailable")
)
View Source
var (
	ErrUnreachable = errors.New("can't connect to agent")
)

Functions

func CreatePidFile added in v0.0.234

func CreatePidFile() error

func InitAgentLogs added in v0.0.234

func InitAgentLogs() error

func IsAgentStartError added in v0.0.234

func IsAgentStartError(err error) bool

func IsHostNotFoundError added in v0.0.233

func IsHostNotFoundError(err error) bool

func IsIPv6 added in v0.0.233

func IsIPv6(addr string) bool

func IsTunnelError added in v0.0.233

func IsTunnelError(err error) bool

func RemovePidFile added in v0.0.234

func RemovePidFile() error

func StopRunningAgent added in v0.0.234

func StopRunningAgent() error

Types

type AgentStartError added in v0.0.234

type AgentStartError struct {
	Output string
}

func (*AgentStartError) Description added in v0.0.234

func (e *AgentStartError) Description() string

func (*AgentStartError) Error added in v0.0.234

func (e *AgentStartError) Error() string

func (*AgentStartError) Suggestion added in v0.0.234

func (e *AgentStartError) Suggestion() string

type Client

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

func DefaultClient

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

func Establish added in v0.0.233

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, apiClient *api.Client) (*Client, error)

func StartDaemon added in v0.0.233

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) (*EstablishResponse, 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) (PingResponse, error)

func (*Client) Probe

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

func (*Client) Resolve added in v0.0.233

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

func (*Client) WaitForHost added in v0.0.233

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

func (*Client) WaitForTunnel added in v0.0.233

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

type ClosableWrite added in v0.0.233

type ClosableWrite interface {
	CloseWrite() error
}

type Dialer

type Dialer interface {
	State() *wg.WireGuardState
	Config() *wg.Config
	DialContext(ctx context.Context, network, addr string) (net.Conn, error)
}

type EstablishResponse added in v0.0.240

type EstablishResponse struct {
	WireGuardState *wg.WireGuardState
	TunnelConfig   *wg.Config
}

type HostNotFoundError added in v0.0.233

type HostNotFoundError struct {
	OrgSlug string
	Host    string
	Err     error
}

func (*HostNotFoundError) Error added in v0.0.233

func (e *HostNotFoundError) Error() string

func (*HostNotFoundError) Unwrap added in v0.0.233

func (e *HostNotFoundError) Unwrap() error

type Instances

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

type PingResponse added in v0.0.234

type PingResponse struct {
	PID        int
	Version    semver.Version
	Background bool
}

type Server

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

func DefaultServer

func DefaultServer(apiClient *api.Client, background bool) (*Server, error)

func NewServer

func NewServer(path string, apiClient *api.Client, background bool) (*Server, error)

func (*Server) Serve

func (s *Server) Serve()

func (*Server) Stop added in v0.0.234

func (s *Server) Stop()

func (*Server) Wait added in v0.0.234

func (s *Server) Wait()

type TunnelError added in v0.0.233

type TunnelError struct {
	OrgSlug string
	Err     error
}

func (*TunnelError) Error added in v0.0.233

func (e *TunnelError) Error() string

func (*TunnelError) Unwrap added in v0.0.233

func (e *TunnelError) Unwrap() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL