mux

Sep 27, 2026

Changes in this version

+ func ContextWithKeepSession(ctx context.Context) context.Context

type Client

+ func (c *Client) CloseIdleConnections()

+ func (c *Client) SetKeepIdleConnections(keep bool)

Feb 6, 2025

Changes in this version

+ const StreamVersion1

+ func EncodeBrutalRequest(receiveBPS uint64) *buf.Buffer

type Client

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

type Service

+ func (s *Service) NewConnectionEx(ctx context.Context, conn net.Conn, source M.Socksaddr, ...)

+ type ServiceHandlerEx interface

type ServiceOptions

+ HandlerEx ServiceHandlerEx

type StreamRequest

+ Version byte

Dec 4, 2023

Changes in this version

+ const BrutalAvailable

+ const BrutalExchangeDomain

+ const BrutalMinSpeedBPS

+ const TCP_BRUTAL_PARAMS — linux/amd64

+ func ReadBrutalRequest(reader io.Reader) (uint64, error)

+ func ReadBrutalResponse(reader io.Reader) (uint64, error)

+ func SetBrutalOptions(conn net.Conn, sendBPS uint64) error

+ func WriteBrutalRequest(writer io.Writer, receiveBPS uint64) error

+ func WriteBrutalResponse(writer io.Writer, receiveBPS uint64, ok bool, message string) error

+ type BrutalOptions struct

+ Enabled bool

+ ReceiveBPS uint64

+ SendBPS uint64

type Options

+ Brutal BrutalOptions

+ Logger logger.Logger

+ type Service struct

+ func NewService(options ServiceOptions) (*Service, error)

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

+ type ServiceHandler interface

+ type ServiceOptions struct

+ Brutal BrutalOptions

+ Handler ServiceHandler

+ Logger logger.ContextLogger

+ NewStreamContext func(context.Context, net.Conn) context.Context

+ Padding bool

+ type TCPBrutalParams struct — linux/amd64

+ CwndGain uint32

+ Rate uint64

Jun 17, 2023

Changes in this version

+ const ProtocolH2Mux

+ const ProtocolSmux

+ const ProtocolYAMux

+ const TCPTimeout

+ const Version0

+ const Version1

+ var Destination = M.Socksaddr

+ func EncodeRequest(request Request, payload []byte) *buf.Buffer

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

+ func HandleConnection(ctx context.Context, handler ServerHandler, logger logger.ContextLogger, ...) error

+ func HandleConnectionDefault(ctx context.Context, conn net.Conn) error

+ type Client struct

+ func NewClient(options Options) (*Client, error)

+ 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)

+ func (c *Client) Reset()

+ type Options struct

+ Dialer N.Dialer

+ MaxConnections int

+ MaxStreams int

+ MinStreams int

+ Padding bool

+ Protocol string

+ type Request struct

+ Padding bool

+ Protocol byte

+ Version byte

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

+ type ServerHandler interface

+ 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)