transport

Documentation

Index

• Constants
• Variables
• type AddrEx
  • func (a *AddrEx) String() string
• type ClientTransport
  • func (ct *ClientTransport) DialTCP(raddr *net.TCPAddr) (*net.TCPConn, error)
  • func (ct *ClientTransport) ListenUDP() (*net.UDPConn, error)
  • func (ct *ClientTransport) QUICDial(proto string, server string, tlsConfig *tls.Config, quicConfig *quic.Config, ...) (quic.Connection, error)
  • func (ct *ClientTransport) ResolveIPAddr(address string) (*net.IPAddr, error)
• type PUDPConn
• type ResolvePreference
  • func ResolvePreferenceFromString(preference string) (ResolvePreference, error)
• type SOCKS5Client
  • func NewSOCKS5Client(serverAddr string, username string, password string, negTimeout time.Duration) (*SOCKS5Client, error)
  • func (c *SOCKS5Client) DialTCP(raddr *AddrEx) (*net.TCPConn, error)
  • func (c *SOCKS5Client) ListenUDP() (*socks5UDPConn, error)
• type ServerTransport
  • func (st *ServerTransport) DialTCP(raddr *AddrEx) (*net.TCPConn, error)
  • func (st *ServerTransport) ListenUDP() (PUDPConn, error)
  • func (st *ServerTransport) QUICListen(proto string, listen string, tlsConfig *tls.Config, quicConfig *quic.Config, ...) (quic.Listener, error)
  • func (st *ServerTransport) ResolveIPAddr(address string) (*net.IPAddr, bool, error)
  • func (st *ServerTransport) SOCKS5Enabled() bool

Constants

const (
	ResolvePreferenceDefault = ResolvePreference(iota)
	ResolvePreferenceIPv4
	ResolvePreferenceIPv6
	ResolvePreferenceIPv4OrIPv6
	ResolvePreferenceIPv6OrIPv4

	ResolveTimeout = 8 * time.Second
)

Variables

var DefaultClientTransport = &ClientTransport{
	Dialer: &net.Dialer{
		Timeout: 8 * time.Second,
	},
	ResolvePreference: ResolvePreferenceDefault,
}

var DefaultServerTransport = &ServerTransport{
	Dialer: &net.Dialer{
		Timeout: 8 * time.Second,
	},
	ResolvePreference: ResolvePreferenceDefault,
}

Types

type AddrEx

type AddrEx struct {
	Domain string
	IPAddr *net.IPAddr
	Port   int
}

AddrEx is like net.TCPAddr or net.UDPAddr, but with additional domain information for SOCKS5. At least one of Domain and IPAddr must be non-empty.

func (*AddrEx) String

func (a *AddrEx) String() string

type ClientTransport

type ClientTransport struct {
	Dialer            *net.Dialer
	ResolvePreference ResolvePreference
}

func (*ClientTransport) DialTCP

func (ct *ClientTransport) DialTCP(raddr *net.TCPAddr) (*net.TCPConn, error)

func (*ClientTransport) ListenUDP

func (ct *ClientTransport) ListenUDP() (*net.UDPConn, error)

func (*ClientTransport) QUICDial

func (ct *ClientTransport) QUICDial(proto string, server string, tlsConfig *tls.Config, quicConfig *quic.Config, obfs obfs.Obfuscator) (quic.Connection, error)

func (*ClientTransport) ResolveIPAddr

func (ct *ClientTransport) ResolveIPAddr(address string) (*net.IPAddr, error)

type PUDPConn

type PUDPConn interface {
	ReadFromUDP([]byte) (int, *net.UDPAddr, error)
	WriteToUDP([]byte, *AddrEx) (int, error)
	Close() error
}

type ResolvePreference

type ResolvePreference int

func ResolvePreferenceFromString

func ResolvePreferenceFromString(preference string) (ResolvePreference, error)

type SOCKS5Client

type SOCKS5Client struct {
	ServerTCPAddr *net.TCPAddr
	Username      string
	Password      string
	NegTimeout    time.Duration
}

func NewSOCKS5Client

func NewSOCKS5Client(serverAddr string, username string, password string, negTimeout time.Duration) (*SOCKS5Client, error)

func (*SOCKS5Client) DialTCP

func (c *SOCKS5Client) DialTCP(raddr *AddrEx) (*net.TCPConn, error)

func (*SOCKS5Client) ListenUDP

func (c *SOCKS5Client) ListenUDP() (*socks5UDPConn, error)

type ServerTransport

type ServerTransport struct {
	Dialer            *net.Dialer
	SOCKS5Client      *SOCKS5Client
	ResolvePreference ResolvePreference
	LocalUDPAddr      *net.UDPAddr
	LocalUDPIntf      *net.Interface
}

func (*ServerTransport) DialTCP

func (st *ServerTransport) DialTCP(raddr *AddrEx) (*net.TCPConn, error)

func (*ServerTransport) ListenUDP

func (st *ServerTransport) ListenUDP() (PUDPConn, error)

func (*ServerTransport) QUICListen

func (st *ServerTransport) QUICListen(proto string, listen string, tlsConfig *tls.Config, quicConfig *quic.Config, obfs obfs.Obfuscator) (quic.Listener, error)

func (*ServerTransport) ResolveIPAddr

func (st *ServerTransport) ResolveIPAddr(address string) (*net.IPAddr, bool, error)

func (*ServerTransport) SOCKS5Enabled

func (st *ServerTransport) SOCKS5Enabled() bool