snell

Documentation

Index

• Constants
• func HalfClose(conn net.Conn) error
• func NewAES128GCM(psk []byte) shadowaead.Cipher
• func NewChacha20Poly1305(psk []byte) shadowaead.Cipher
• func PacketConn(conn net.Conn) net.PacketConn
• func ReadPacket(r io.Reader, payload []byte) (net.Addr, int, error)
• func UdpRequestHeaderLength(socks5Addr []byte) int
• func WriteHeader(conn net.Conn, host string, port uint, version int) error
• func WriteHeaderWithReuse(conn net.Conn, host string, port uint, version int, reuse bool) error
• func WritePacket(w io.Writer, socks5Addr, payload []byte) (int, error)
• func WritePacketResponse(w io.Writer, addr net.Addr, payload []byte) (int, error)
• func WriteUDPHeader(conn net.Conn, version int) error
• type Pool
  • func NewPool(factory func(context.Context) (*Snell, error)) *Pool
  • func (p *Pool) Get() (net.Conn, error)
  • func (p *Pool) GetContext(ctx context.Context) (net.Conn, error)
  • func (p *Pool) Put(conn *Snell)
• type PoolConn
  • func (pc *PoolConn) Close() error
  • func (pc *PoolConn) CloseWrite() error
  • func (pc *PoolConn) MarkReusable()
  • func (pc *PoolConn) Read(b []byte) (int, error)
  • func (pc *PoolConn) Write(b []byte) (int, error)
• type Snell
  • func ServerStreamConn(conn net.Conn, psk []byte, version int) *Snell
  • func StreamConn(conn net.Conn, psk []byte, version int) *Snell
  • func (s *Snell) Read(b []byte) (int, error)
  • func (s *Snell) ReadReply() error
  • func (s *Snell) WritePacketFrame(b []byte) (int, error)
• type UDPRequest
  • func ParseUDPRequest(packet []byte) (UDPRequest, error)

Constants

const (
	Version1            = 1
	Version2            = 2
	Version3            = 3
	Version4            = 4
	Version5            = 5
	DefaultSnellVersion = Version1
)

const (
	CommandPing       byte = 0
	CommandConnect    byte = 1
	CommandConnectV2  byte = 5
	CommandUDP        byte = 6
	CommondUDPForward byte = 1

	CommandTunnel byte = 0
	CommandPong   byte = 1
	CommandError  byte = 2

	Version byte = 1
)

Functions

func HalfClose

func HalfClose(conn net.Conn) error

HalfClose only works after the request negotiated the reuse command.

func NewAES128GCM

func NewAES128GCM(psk []byte) shadowaead.Cipher

func NewChacha20Poly1305

func NewChacha20Poly1305(psk []byte) shadowaead.Cipher

func PacketConn

func PacketConn(conn net.Conn) net.PacketConn

func ReadPacket

func ReadPacket(r io.Reader, payload []byte) (net.Addr, int, error)

func UdpRequestHeaderLength

func UdpRequestHeaderLength(socks5Addr []byte) int

func WriteHeader

func WriteHeader(conn net.Conn, host string, port uint, version int) error

func WriteHeaderWithReuse

func WriteHeaderWithReuse(conn net.Conn, host string, port uint, version int, reuse bool) error

func WritePacket

func WritePacket(w io.Writer, socks5Addr, payload []byte) (int, error)

func WritePacketResponse

func WritePacketResponse(w io.Writer, addr net.Addr, payload []byte) (int, error)

func WriteUDPHeader

func WriteUDPHeader(conn net.Conn, version int) error

Types

type Pool

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

func NewPool

func NewPool(factory func(context.Context) (*Snell, error)) *Pool

func (*Pool) Get

func (p *Pool) Get() (net.Conn, error)

func (*Pool) GetContext

func (p *Pool) GetContext(ctx context.Context) (net.Conn, error)

func (*Pool) Put

func (p *Pool) Put(conn *Snell)

type PoolConn

type PoolConn struct {
	*Snell
	// contains filtered or unexported fields
}

func (*PoolConn) Close

func (pc *PoolConn) Close() error

func (*PoolConn) CloseWrite

func (pc *PoolConn) CloseWrite() error

func (*PoolConn) MarkReusable

func (pc *PoolConn) MarkReusable()

MarkReusable allows Close to return this request to the pool after the request header is committed.

func (*PoolConn) Read

func (pc *PoolConn) Read(b []byte) (int, error)

func (*PoolConn) Write

func (pc *PoolConn) Write(b []byte) (int, error)

type Snell

type Snell struct {
	net.Conn
	// contains filtered or unexported fields
}

func ServerStreamConn

func ServerStreamConn(conn net.Conn, psk []byte, version int) *Snell

func StreamConn

func StreamConn(conn net.Conn, psk []byte, version int) *Snell

func (*Snell) Read

func (s *Snell) Read(b []byte) (int, error)

func (*Snell) ReadReply

func (s *Snell) ReadReply() error

func (*Snell) WritePacketFrame

func (s *Snell) WritePacketFrame(b []byte) (int, error)

type UDPRequest

type UDPRequest struct {
	Host    string
	Ip      netip.Addr
	Port    uint16
	Payload []byte
}

func ParseUDPRequest

func ParseUDPRequest(packet []byte) (UDPRequest, error)