xnet

Documentation

Index

• Constants
• func IsClosedConnectionError(err error) bool
• func JoinHostPort(host string, port uint16) string
• func NewRequestID() string
• func ProxyTCP(reqID string, downConn, upConn *net.TCPConn)
• func ProxyUDP(reqID string, downConn *net.TCPConn, upConn net.Conn)
• func ReadUDPFromStream(r io.Reader, buf []byte, timeout time.Duration) (n int, err error)
• type AckCode
  • func (c AckCode) Error() string
• type Acknowledgement
  • func (a *Acknowledgement) FromReader(r io.Reader) error
  • func (a *Acknowledgement) Marshal() []byte
• type Addr
  • func AddrFromBytes(addrType byte, data []byte) Addr
  • func AddrFromHost(host string) Addr
  • func AddrFromIP(ipStr string) (Addr, error)
  • func (a *Addr) IsZero() bool
  • func (a *Addr) Marshal() []byte
  • func (a *Addr) String() string
• type Header
  • func (h *Header) FromReader(r io.Reader) error
  • func (h *Header) Marshal() []byte
• type UDPConn
  • func (c *UDPConn) Read(buf []byte) (n int, err error)
  • func (c *UDPConn) ReadFrom(buf []byte) (n int, addr net.Addr, err error)

Constants

const (
	AckCodeOK = iota + 1
	AckCodeUnknownError
	AckCodeNoSuchHost
	AckCodeResolveTimeout
	AckCodeConnectTimeout
	AckCodeUnknownProtocol
)

const (
	AddrTypeIP byte = iota
	AddrTypeHost
)

const (
	ProtocolTCP byte = iota
	ProtocolUDP
)

Functions

func IsClosedConnectionError

func IsClosedConnectionError(err error) bool

func JoinHostPort

func JoinHostPort(host string, port uint16) string

func NewRequestID

func NewRequestID() string

func ProxyTCP

func ProxyTCP(reqID string, downConn, upConn *net.TCPConn)

ProxyTCP is excerpt from https://stackoverflow.com/a/27445109/4725840

func ProxyUDP

func ProxyUDP(reqID string, downConn *net.TCPConn, upConn net.Conn)

func ReadUDPFromStream

func ReadUDPFromStream(r io.Reader, buf []byte, timeout time.Duration) (n int, err error)

Types

type AckCode

type AckCode uint8

func (AckCode) Error

func (c AckCode) Error() string

type Acknowledgement

type Acknowledgement struct {
	Code AckCode
}

func (*Acknowledgement) FromReader

func (a *Acknowledgement) FromReader(r io.Reader) error

func (*Acknowledgement) Marshal

func (a *Acknowledgement) Marshal() []byte

type Addr

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

func AddrFromBytes

func AddrFromBytes(addrType byte, data []byte) Addr

func AddrFromHost

func AddrFromHost(host string) Addr

func AddrFromIP

func AddrFromIP(ipStr string) (Addr, error)

func (*Addr) IsZero

func (a *Addr) IsZero() bool

func (*Addr) Marshal

func (a *Addr) Marshal() []byte

func (*Addr) String

func (a *Addr) String() string

type Header

type Header struct {
	Version   byte
	RequestID string
	Protocol  byte
	Port      uint16
	Addr      Addr
}

func (*Header) FromReader

func (h *Header) FromReader(r io.Reader) error

func (*Header) Marshal

func (h *Header) Marshal() []byte

type UDPConn

type UDPConn struct {
	*net.UDPConn
}

UDPConn wraps a *net.UDPConn and overrides the Read and ReadFrom methods to automatically prepend the length of the packet.

func (*UDPConn) Read

func (c *UDPConn) Read(buf []byte) (n int, err error)

func (*UDPConn) ReadFrom

func (c *UDPConn) ReadFrom(buf []byte) (n int, addr net.Addr, err error)