tunnel

Documentation

Index

• Constants
• Variables
• func NewHandler(opts ...handler.Option) handler.Handler
• type Connector
  • func NewConnector(id relay.ConnectorID, tid relay.TunnelID, node string, s *mux.Session, ...) *Connector
  • func (c *Connector) ID() relay.ConnectorID
  • func (c *Connector) Session() *mux.Session
• type ConnectorPool
  • func NewConnectorPool(node string, sd sd.SD) *ConnectorPool
  • func (p *ConnectorPool) Add(tid relay.TunnelID, c *Connector, ttl time.Duration)
  • func (p *ConnectorPool) Get(network string, tid string) *Connector
• type Dialer
  • func (d *Dialer) Dial(ctx context.Context, network string, tid string) (conn net.Conn, node string, cid string, err error)
• type Tunnel
  • func NewTunnel(node string, tid relay.TunnelID, ttl time.Duration) *Tunnel
  • func (t *Tunnel) AddConnector(c *Connector)
  • func (t *Tunnel) CloseOnIdle() bool
  • func (t *Tunnel) GetConnector(network string) *Connector
  • func (t *Tunnel) ID() relay.TunnelID
  • func (t *Tunnel) WithSD(sd sd.SD)

Constants

const (
	MaxWeight uint8 = 0xff
)

Variables

var (
	ErrBadVersion         = errors.New("bad version")
	ErrUnknownCmd         = errors.New("unknown command")
	ErrTunnelID           = errors.New("invalid tunnel ID")
	ErrTunnelNotAvailable = errors.New("tunnel not available")
	ErrUnauthorized       = errors.New("unauthorized")
	ErrRateLimit          = errors.New("rate limiting exceeded")
)

Functions

func NewHandler

func NewHandler(opts ...handler.Option) handler.Handler

Types

type Connector

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

func NewConnector

func NewConnector(id relay.ConnectorID, tid relay.TunnelID, node string, s *mux.Session, sd sd.SD) *Connector

func (*Connector) ID

func (c *Connector) ID() relay.ConnectorID

func (*Connector) Session

func (c *Connector) Session() *mux.Session

type ConnectorPool

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

func NewConnectorPool

func NewConnectorPool(node string, sd sd.SD) *ConnectorPool

func (*ConnectorPool) Add

func (p *ConnectorPool) Add(tid relay.TunnelID, c *Connector, ttl time.Duration)

func (*ConnectorPool) Get

func (p *ConnectorPool) Get(network string, tid string) *Connector

type Dialer

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

func (*Dialer) Dial

func (d *Dialer) Dial(ctx context.Context, network string, tid string) (conn net.Conn, node string, cid string, err error)

type Tunnel

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

func NewTunnel

func NewTunnel(node string, tid relay.TunnelID, ttl time.Duration) *Tunnel

func (*Tunnel) AddConnector

func (t *Tunnel) AddConnector(c *Connector)

func (*Tunnel) CloseOnIdle

func (t *Tunnel) CloseOnIdle() bool

func (*Tunnel) GetConnector

func (t *Tunnel) GetConnector(network string) *Connector

func (*Tunnel) ID

func (t *Tunnel) ID() relay.TunnelID

func (*Tunnel) WithSD

func (t *Tunnel) WithSD(sd sd.SD)