Versions in this module Expand all Collapse all v0 v0.0.1 Sep 18, 2023 Changes in this version + const FlowVision + const Version + func EncodeRequest(request Request, buffer *buf.Buffer) error + func ReadResponse(reader io.Reader) error + func RequestLen(request Request) int + func WritePacketRequest(writer io.Writer, request Request, payload []byte) error + func WriteRequest(writer io.Writer, request Request, payload []byte) error + type Addons struct + Flow string + Seed string + type Client struct + func NewClient(userId string, flow string, logger logger.Logger) (*Client, error) + func (c *Client) DialConn(conn net.Conn, destination M.Socksaddr) (net.Conn, error) + func (c *Client) DialEarlyConn(conn net.Conn, destination M.Socksaddr) (net.Conn, error) + func (c *Client) DialEarlyPacketConn(conn net.Conn, destination M.Socksaddr) (*PacketConn, error) + func (c *Client) DialEarlyXUDPPacketConn(conn net.Conn, destination M.Socksaddr) (vmess.PacketConn, error) + func (c *Client) DialPacketConn(conn net.Conn, destination M.Socksaddr) (*PacketConn, error) + func (c *Client) DialXUDPPacketConn(conn net.Conn, destination M.Socksaddr) (vmess.PacketConn, error) + type Conn struct + func NewConn(conn net.Conn, uuid [16]byte, command byte, destination M.Socksaddr, ...) *Conn + func (c *Conn) FrontHeadroom() int + func (c *Conn) NeedHandshake() bool + func (c *Conn) Read(b []byte) (n int, err error) + func (c *Conn) ReadBuffer(buffer *buf.Buffer) error + func (c *Conn) ReaderReplaceable() bool + func (c *Conn) Upstream() any + func (c *Conn) Write(b []byte) (n int, err error) + func (c *Conn) WriteBuffer(buffer *buf.Buffer) error + func (c *Conn) WriteVectorised(buffers []*buf.Buffer) error + func (c *Conn) WriterReplaceable() bool + type Handler interface + type PacketConn struct + func (c *PacketConn) FrontHeadroom() int + func (c *PacketConn) NeedAdditionalReadDeadline() bool + func (c *PacketConn) Read(b []byte) (n int, err error) + func (c *PacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error) + func (c *PacketConn) Upstream() any + func (c *PacketConn) Write(b []byte) (n int, err error) + func (c *PacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error + func (c *PacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error) + type Request struct + Command byte + Destination M.Socksaddr + Flow string + UUID [16]byte + func ReadRequest(reader io.Reader) (*Request, error) + type Service struct + func NewService(logger logger.Logger, handler Handler) *Service[T] + func (s *Service[T]) NewConnection(ctx context.Context, conn net.Conn, metadata M.Metadata) error + func (s *Service[T]) UpdateUsers(userList []T, userUUIDList []string, userFlowList []string) + type VisionConn struct + func NewVisionConn(conn net.Conn, tlsConn net.Conn, userUUID [16]byte, logger logger.Logger) (*VisionConn, error) + func (c *VisionConn) NeedAdditionalReadDeadline() bool + func (c *VisionConn) Read(p []byte) (n int, err error) + func (c *VisionConn) Upstream() any + func (c *VisionConn) Write(p []byte) (n int, err error)