tunnel

Documentation

Index

• Constants
• Variables
• func NewHandler(opts ...handler.Option) handler.IHandler
• type Connector
  • func NewConnector(id relay.ConnectorID, tid relay.TunnelID, node string, s *mux.Session, ...) *Connector
  • func (c *Connector) Close() error
  • func (c *Connector) GetConn() (net.Conn, error)
  • func (c *Connector) ID() relay.ConnectorID
  • func (c *Connector) IsClosed() bool
• type ConnectorOptions
• type ConnectorPool
  • func NewConnectorPool(node string) *ConnectorPool
  • func (p *ConnectorPool) Add(tid relay.TunnelID, c *Connector, ttl time.Duration)
  • func (p *ConnectorPool) Close() error
  • 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) Close() error
  • func (t *Tunnel) CloseOnIdle() bool
  • func (t *Tunnel) GetConnector(network string) *Connector
  • func (t *Tunnel) ID() relay.TunnelID

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")
	ErrTunnelRoute        = errors.New("no route to host")
	ErrPrivateTunnel      = errors.New("private tunnel")
)

Functions

func NewHandler

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

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, opts *ConnectorOptions) *Connector

func (*Connector) Close

func (c *Connector) Close() error

func (*Connector) GetConn

func (c *Connector) GetConn() (net.Conn, error)

func (*Connector) ID

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

func (*Connector) IsClosed

func (c *Connector) IsClosed() bool

type ConnectorOptions

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

type ConnectorPool

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

func NewConnectorPool

func NewConnectorPool(node string) *ConnectorPool

func (*ConnectorPool) Add

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

func (*ConnectorPool) Close

func (p *ConnectorPool) Close() error

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) Close

func (t *Tunnel) Close() error

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