vless

Documentation

Index

• Constants
• 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
• type Client
  • 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
  • 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
• type PacketConn
  • 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
  • func ReadRequest(reader io.Reader) (*Request, error)
• type Service
  • func NewService[T comparable](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
  • 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)

Constants

const (
	Version    = 0
	FlowVision = "xtls-rprx-vision"
)

Functions

func EncodeRequest

func EncodeRequest(request Request, buffer *buf.Buffer) error

func ReadResponse

func ReadResponse(reader io.Reader) error

func RequestLen

func RequestLen(request Request) int

func WritePacketRequest

func WritePacketRequest(writer io.Writer, request Request, payload []byte) error

func WriteRequest

func WriteRequest(writer io.Writer, request Request, payload []byte) error

Types

type Addons

type Addons struct {
	Flow string
	Seed string
}

type Client

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

func NewClient

func NewClient(userId string, flow string, logger logger.Logger) (*Client, error)

func (*Client) DialConn

func (c *Client) DialConn(conn net.Conn, destination M.Socksaddr) (net.Conn, error)

func (*Client) DialEarlyConn

func (c *Client) DialEarlyConn(conn net.Conn, destination M.Socksaddr) (net.Conn, error)

func (*Client) DialEarlyPacketConn

func (c *Client) DialEarlyPacketConn(conn net.Conn, destination M.Socksaddr) (*PacketConn, error)

func (*Client) DialEarlyXUDPPacketConn

func (c *Client) DialEarlyXUDPPacketConn(conn net.Conn, destination M.Socksaddr) (vmess.PacketConn, error)

func (*Client) DialPacketConn

func (c *Client) DialPacketConn(conn net.Conn, destination M.Socksaddr) (*PacketConn, error)

func (*Client) DialXUDPPacketConn

func (c *Client) DialXUDPPacketConn(conn net.Conn, destination M.Socksaddr) (vmess.PacketConn, error)

type Conn

type Conn struct {
	N.ExtendedConn
	// contains filtered or unexported fields
}

func NewConn

func NewConn(conn net.Conn, uuid [16]byte, command byte, destination M.Socksaddr, flow string) *Conn

func (*Conn) FrontHeadroom

func (c *Conn) FrontHeadroom() int

func (*Conn) NeedHandshake

func (c *Conn) NeedHandshake() bool

func (*Conn) Read

func (c *Conn) Read(b []byte) (n int, err error)

func (*Conn) ReadBuffer

func (c *Conn) ReadBuffer(buffer *buf.Buffer) error

func (*Conn) ReaderReplaceable

func (c *Conn) ReaderReplaceable() bool

func (*Conn) Upstream

func (c *Conn) Upstream() any

func (*Conn) Write

func (c *Conn) Write(b []byte) (n int, err error)

func (*Conn) WriteBuffer

func (c *Conn) WriteBuffer(buffer *buf.Buffer) error

func (*Conn) WriteVectorised

func (c *Conn) WriteVectorised(buffers []*buf.Buffer) error

func (*Conn) WriterReplaceable

func (c *Conn) WriterReplaceable() bool

type Handler

type Handler interface {
	N.TCPConnectionHandler
	N.UDPConnectionHandler
	E.Handler
}

type PacketConn

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

func (*PacketConn) FrontHeadroom

func (c *PacketConn) FrontHeadroom() int

func (*PacketConn) NeedAdditionalReadDeadline

func (c *PacketConn) NeedAdditionalReadDeadline() bool

func (*PacketConn) Read

func (c *PacketConn) Read(b []byte) (n int, err error)

func (*PacketConn) ReadFrom

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

func (*PacketConn) Upstream

func (c *PacketConn) Upstream() any

func (*PacketConn) Write

func (c *PacketConn) Write(b []byte) (n int, err error)

func (*PacketConn) WritePacket

func (c *PacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

func (*PacketConn) WriteTo

func (c *PacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

type Request

type Request struct {
	UUID        [16]byte
	Command     byte
	Destination M.Socksaddr
	Flow        string
}

func ReadRequest

func ReadRequest(reader io.Reader) (*Request, error)

type Service

type Service[T comparable] struct {
	// contains filtered or unexported fields
}

func NewService

func NewService[T comparable](logger logger.Logger, handler Handler) *Service[T]

func (*Service[T]) NewConnection

func (s *Service[T]) NewConnection(ctx context.Context, conn net.Conn, metadata M.Metadata) error

func (*Service[T]) UpdateUsers

func (s *Service[T]) UpdateUsers(userList []T, userUUIDList []string, userFlowList []string)

type VisionConn

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

func NewVisionConn

func NewVisionConn(conn net.Conn, tlsConn net.Conn, userUUID [16]byte, logger logger.Logger) (*VisionConn, error)

func (*VisionConn) NeedAdditionalReadDeadline

func (c *VisionConn) NeedAdditionalReadDeadline() bool

func (*VisionConn) Read

func (c *VisionConn) Read(p []byte) (n int, err error)

func (*VisionConn) Upstream

func (c *VisionConn) Upstream() any

func (*VisionConn) Write

func (c *VisionConn) Write(p []byte) (n int, err error)