vi

package

v1.0.3 Latest Latest Go to latest Published: Dec 24, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

View Source

const (
	Version = byte(0)
)

View Source

var (
	InvalidUser    = errors.New("invalid user")
	InvalidVersion = errors.New("invalid version")
)

func EncodeHeader(version byte, credential []byte, dest net.Destination, udpUuid uuid.UUID) (*buf.Buffer, error)

EncodeHeader encodes a header into bytes.

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

func NewClient() *Client

New creates a new VLess outbound handler.

func (h *Client) HandleFlow(ctx context.Context, dst net.Destination, rw buf.ReaderWriter) error

Process implements proxy.Outbound.Process().

func (c *Client) HandlePacketConn(ctx context.Context, dst net.Destination, pc udp.PacketReaderWriter) error

TODO

func (h *Client) WithServerPicker(p protocol.ServerPicker) *Client

type Header struct {
	Version byte
	User    string
	Level   uint32
	Dest    net.Destination
	UdpUuid uuid.UUID
}

func DecodeHeader(data *buf.Buffer, um *sync.Map) (*Header, error)

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

func New() *Server

New creates a new VLess inbound handler.

func (h *Server) AddUser(user i.User)

func (*Server) Network() []net.Network

Network implements proxy.Inbound.Network().

func (h *Server) Process(ctx context.Context, conn net.Conn) error

Process implements proxy.Inbound.Process().

func (h *Server) RemoveUser(uuid uuid.UUID)

func (s *Server) WithHandler(h i.Handler)

func (s *Server) WithTimeoutPolicy(policy i.TimeoutSetting)

type User struct {
	Uid    string
	Secret string
}