mux

Nov 29, 2023

Changes in this version

+ func NewRouterWithOptions(router adapter.ConnectionRouter, logger logger.ContextLogger, ...) (adapter.ConnectionRouter, error)

+ func NewV2RayLegacyRouter(router adapter.ConnectionRouter, logger logger.ContextLogger) adapter.ConnectionRouter

+ type Router struct

+ func (r *Router) RouteConnection(ctx context.Context, conn net.Conn, metadata adapter.InboundContext) error

+ func (r *Router) RoutePacketConnection(ctx context.Context, conn N.PacketConn, metadata adapter.InboundContext) error

+ type V2RayLegacyRouter struct

+ func (r *V2RayLegacyRouter) RouteConnection(ctx context.Context, conn net.Conn, metadata adapter.InboundContext) error

+ func (r *V2RayLegacyRouter) RoutePacketConnection(ctx context.Context, conn N.PacketConn, metadata adapter.InboundContext) error

Jun 27, 2023

Changes in this version

+ var HandleConnection = mux.HandleConnection

Apr 21, 2023

Changes in this version

type ClientConn

+ func (c *ClientConn) NeedAdditionalReadDeadline() bool

type ClientPacketAddrConn

+ func (c *ClientPacketAddrConn) NeedAdditionalReadDeadline() bool

type ClientPacketConn

+ func (c *ClientPacketConn) NeedAdditionalReadDeadline() bool

type ServerConn

+ func (c *ServerConn) NeedAdditionalReadDeadline() bool

type ServerPacketAddrConn

+ func (c *ServerPacketAddrConn) NeedAdditionalReadDeadline() bool

type ServerPacketConn

+ func (c *ServerPacketConn) NeedAdditionalReadDeadline() bool

Dec 3, 2022

Changes in this version

type ClientPacketConn

+ func (c *ClientPacketConn) ReadBuffer(buffer *buf.Buffer) (err error)

+ func (c *ClientPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

Aug 12, 2022

Changes in this version

+ var Destination = M.Socksaddr

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

+ func EncodeStreamRequest(request StreamRequest, buffer *buf.Buffer)

+ func NewClientWithOptions(ctx context.Context, dialer N.Dialer, options option.MultiplexOptions) (N.Dialer, error)

+ func NewConnection(ctx context.Context, router adapter.Router, errorHandler E.Handler, ...) error

+ type Client struct

+ func NewClient(ctx context.Context, dialer N.Dialer, protocol Protocol, maxConnections int, ...) *Client

+ func (c *Client) Close() error

+ func (c *Client) DialContext(ctx context.Context, network string, destination M.Socksaddr) (net.Conn, error)

+ func (c *Client) ListenPacket(ctx context.Context, destination M.Socksaddr) (net.PacketConn, error)

+ type ClientConn struct

+ func (c *ClientConn) LocalAddr() net.Addr

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

+ func (c *ClientConn) ReadFrom(r io.Reader) (n int64, err error)

+ func (c *ClientConn) ReaderReplaceable() bool

+ func (c *ClientConn) RemoteAddr() net.Addr

+ func (c *ClientConn) Upstream() any

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

+ func (c *ClientConn) WriteTo(w io.Writer) (n int64, err error)

+ func (c *ClientConn) WriterReplaceable() bool

+ type ClientPacketAddrConn struct

+ func (c *ClientPacketAddrConn) FrontHeadroom() int

+ func (c *ClientPacketAddrConn) LocalAddr() net.Addr

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

+ func (c *ClientPacketAddrConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

+ func (c *ClientPacketAddrConn) Upstream() any

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

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

+ type ClientPacketConn struct

+ func (c *ClientPacketConn) FrontHeadroom() int

+ func (c *ClientPacketConn) LocalAddr() net.Addr

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

+ func (c *ClientPacketConn) RemoteAddr() net.Addr

+ func (c *ClientPacketConn) Upstream() any

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

+ func (c *ClientPacketConn) WriteBuffer(buffer *buf.Buffer) error

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

+ type Protocol byte

+ const ProtocolSMux

+ const ProtocolYAMux

+ func ParseProtocol(name string) (Protocol, error)

+ func (p Protocol) String() string

+ type Request struct

+ Protocol Protocol

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

+ type ServerConn struct

+ func (c *ServerConn) FrontHeadroom() int

+ func (c *ServerConn) HandshakeFailure(err error) error

+ func (c *ServerConn) Upstream() any

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

+ func (c *ServerConn) WriteBuffer(buffer *buf.Buffer) error

+ type ServerPacketAddrConn struct

+ func (c *ServerPacketAddrConn) FrontHeadroom() int

+ func (c *ServerPacketAddrConn) HandshakeFailure(err error) error

+ func (c *ServerPacketAddrConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

+ func (c *ServerPacketAddrConn) Upstream() any

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

+ type ServerPacketConn struct

+ func (c *ServerPacketConn) FrontHeadroom() int

+ func (c *ServerPacketConn) HandshakeFailure(err error) error

+ func (c *ServerPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

+ func (c *ServerPacketConn) Upstream() any

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

+ type StreamRequest struct

+ Destination M.Socksaddr

+ Network string

+ PacketAddr bool

+ func ReadStreamRequest(reader io.Reader) (*StreamRequest, error)

+ type StreamResponse struct

+ Message string

+ Status uint8

+ func ReadStreamResponse(reader io.Reader) (*StreamResponse, error)