nt

Documentation

Index

• func ConvertICMPError(msg *icmp.Message, ip *net.IPAddr, ver int) (message.UDPErrorType, netip.Addr, []byte)
• func DialWithOption(ctx context.Context, addr message.SocksAddr, opt message.StackOptionInfo) (net.Conn, message.StackOptionInfo, error)
• func Drain(c io.Reader) error
• func GuessDefaultIPv4() net.IP
• func GuessDefaultIPv6() net.IP
• func ListenPacketWithOption(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.PacketConn, message.StackOptionInfo, error)
• func ListenerWithOption(ctx context.Context, addr message.SocksAddr, opt message.StackOptionInfo) (net.Listener, message.StackOptionInfo, error)
• func OnReadError(c io.Reader, f func(error))
• func ParseSrcDstAddrFromIPHeader(header []byte, version int) (src, dst netip.AddrPort, proto int, e error)
• func Relay(ctx context.Context, c, r net.Conn, timeout time.Duration) error
• func SetConnOption(conn net.Conn, opt message.StackOptionInfo) message.StackOptionInfo
• func SetPacketConnOption(conn net.PacketConn, opt message.StackOptionInfo) message.StackOptionInfo
• func UDPPortAvaliable(a netip.AddrPort) bool
• type BufferPrefixedConn
  • func NewBufferPrefixedConn(c net.Conn, b []byte) *BufferPrefixedConn
  • func (bc *BufferPrefixedConn) Read(b []byte) (int, error)
• type BufferPrefixedReader
  • func NewBufferPrefixedReader(r io.Reader, b []byte) *BufferPrefixedReader
  • func (br *BufferPrefixedReader) Read(b []byte) (int, error)
• type Datagram
  • func ReadPacketDatagram(pc net.PacketConn) (Datagram, error)
• type DualModeMultiplexedConn
  • func WrapQUICConn(conn quic.Connection) DualModeMultiplexedConn
• type InternetOutbound
  • func (i InternetOutbound) Dial(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Conn, message.StackOptionInfo, error)
  • func (i InternetOutbound) Listen(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Listener, message.StackOptionInfo, error)
  • func (i InternetOutbound) ListenPacket(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.PacketConn, message.StackOptionInfo, error)
  • func (i InternetOutbound) SetConnOption(conn net.Conn, opt message.StackOptionInfo) message.StackOptionInfo
  • func (i InternetOutbound) SetPacketConnOption(conn net.PacketConn, opt message.StackOptionInfo) message.StackOptionInfo
• type MultiplexedConn
• type NetBufferOnlyReader
  • func (n *NetBufferOnlyReader) Read(b []byte) (int, error)
• type Outbound
• type SeqPacket
  • func WrapConnSeqPacket(conn net.Conn) SeqPacket

Functions

func ConvertICMPError

func ConvertICMPError(msg *icmp.Message, ip *net.IPAddr, ver int,
) (message.UDPErrorType, netip.Addr, []byte)

func DialWithOption

func DialWithOption(ctx context.Context, addr message.SocksAddr, opt message.StackOptionInfo) (net.Conn, message.StackOptionInfo, error)

func Drain

func Drain(c io.Reader) error

func GuessDefaultIPv4

func GuessDefaultIPv4() net.IP

func GuessDefaultIPv6

func GuessDefaultIPv6() net.IP

func ListenPacketWithOption

func ListenPacketWithOption(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.PacketConn, message.StackOptionInfo, error)

func ListenerWithOption

func ListenerWithOption(ctx context.Context, addr message.SocksAddr, opt message.StackOptionInfo) (net.Listener, message.StackOptionInfo, error)

func OnReadError

func OnReadError(c io.Reader, f func(error))

func ParseSrcDstAddrFromIPHeader

func ParseSrcDstAddrFromIPHeader(header []byte, version int) (src, dst netip.AddrPort, proto int, e error)

func Relay

func Relay(ctx context.Context, c, r net.Conn, timeout time.Duration) error

func SetConnOption

func SetConnOption(conn net.Conn, opt message.StackOptionInfo) message.StackOptionInfo

func SetPacketConnOption

func SetPacketConnOption(conn net.PacketConn, opt message.StackOptionInfo) message.StackOptionInfo

func UDPPortAvaliable

func UDPPortAvaliable(a netip.AddrPort) bool

Types

type BufferPrefixedConn

type BufferPrefixedConn struct {
	BufferPrefixedReader
	// contains filtered or unexported fields
}

BufferPrefixedConn is a net.Conn with BufferPrefixedReader.

func NewBufferPrefixedConn

func NewBufferPrefixedConn(c net.Conn, b []byte) *BufferPrefixedConn

func (*BufferPrefixedConn) Read

func (bc *BufferPrefixedConn) Read(b []byte) (int, error)

type BufferPrefixedReader

type BufferPrefixedReader struct {
	Reader io.Reader
	Buffer []byte
	// contains filtered or unexported fields
}

BufferPrefixedReader is an io.Reader which first read from Buffer, then from another io.Reader.

func NewBufferPrefixedReader

func NewBufferPrefixedReader(r io.Reader, b []byte) *BufferPrefixedReader

func (*BufferPrefixedReader) Read

func (br *BufferPrefixedReader) Read(b []byte) (int, error)

Read implements io.Reader.

type Datagram

type Datagram interface {
	Data() []byte
	Reply(b []byte) error
	// contains filtered or unexported methods
}

func ReadPacketDatagram

func ReadPacketDatagram(pc net.PacketConn) (Datagram, error)

type DualModeMultiplexedConn

type DualModeMultiplexedConn interface {
	MultiplexedConn
	SeqPacket
}

func WrapQUICConn

func WrapQUICConn(conn quic.Connection) DualModeMultiplexedConn

type InternetOutbound

type InternetOutbound struct{}

InternetOutbound implements ServerOutbound, create a internet connection/listener.

func (InternetOutbound) Dial

func (i InternetOutbound) Dial(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Conn, message.StackOptionInfo, error)

func (InternetOutbound) Listen

func (i InternetOutbound) Listen(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Listener, message.StackOptionInfo, error)

func (InternetOutbound) ListenPacket

func (i InternetOutbound) ListenPacket(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.PacketConn, message.StackOptionInfo, error)

func (InternetOutbound) SetConnOption

func (i InternetOutbound) SetConnOption(conn net.Conn, opt message.StackOptionInfo) message.StackOptionInfo

func (InternetOutbound) SetPacketConnOption

func (i InternetOutbound) SetPacketConnOption(conn net.PacketConn, opt message.StackOptionInfo) message.StackOptionInfo

type MultiplexedConn

type MultiplexedConn interface {
	Accept() (net.Conn, error)
	Dial() (net.Conn, error)
	// contains filtered or unexported methods
}

type NetBufferOnlyReader

type NetBufferOnlyReader struct {
	Conn net.Conn
}

NetBufferOnlyReader is a wrapper over net.Conn which try to only read data which already in OS buffer by setting read timeout to 1us.

func (*NetBufferOnlyReader) Read

func (n *NetBufferOnlyReader) Read(b []byte) (int, error)

type Outbound

type Outbound interface {
	Dial(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Conn, message.StackOptionInfo, error)
	Listen(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.Listener, message.StackOptionInfo, error)
	ListenPacket(ctx context.Context, addr message.SocksAddr, option message.StackOptionInfo) (net.PacketConn, message.StackOptionInfo, error)
	SetConnOption(conn net.Conn, opt message.StackOptionInfo) message.StackOptionInfo
	SetPacketConnOption(conn net.PacketConn, opt message.StackOptionInfo) message.StackOptionInfo
}

Outbound is a group of function called by ServerWorker when a connection or listener is needed to fulfill client request.

type SeqPacket

type SeqPacket interface {
	NextDatagram() (Datagram, error)
	Reply(b []byte) error
	// contains filtered or unexported methods
}

func WrapConnSeqPacket

func WrapConnSeqPacket(conn net.Conn) SeqPacket