proxy

Sep 4, 2025

Changes in this version

type Context

+ Extra any

Aug 26, 2025

Changes in this version

+ func IsConnAborted(err error) bool

+ func IsConnReset(err error) bool

+ func IsEOF(err error) bool

type Conn

+ PeekRd *PeekReader

+ type PeekReader struct

+ func (r *PeekReader) Read(p []byte) (int, error)

Aug 22, 2025

Changes in this version

type Config

+ DefaultSNI string

+ Dialer proxy.Dialer

+ Limiter Limiter

type HandshakeFn

+ var HttpNegotiator HandshakeFn = func(ctx *Context) error { ... }

Aug 21, 2025

Changes in this version

+ var ErrNilRequest = errors.New("nil request")

type Config

+ ClientTLSConfig *tls.Config

+ func (c *Config) GetClient() *http.Client

+ func (c *Config) GetDialer() proxy.Dialer

+ func (c *Config) SetLimiter(l Limiter)

+ func (c *Config) SetNegotiator(n Negotiator)

+ func (c *Config) SetProxy(rawURL string) error

type Conn

+ func (c *Conn) GetTeeReader() io.Reader

+ func (c *Conn) IsTLS() bool

type Context

+ DstConn net.Conn

type Resolver

+ GetPTR func(string) (string, bool)

+ SetPTR func(string, string)

type StdResolver

+ func (r StdResolver) GetPTR(ip string) (string, bool)

+ func (r StdResolver) SetPTR(ip string, domain string)

Aug 14, 2025

Changes in this version

type Conn

+ func (c *Conn) Reader() *bufio.Reader

Aug 13, 2025

Changes in this version

type Config

+ Resolver Resolver

type Conn

+ func (c *Conn) TeeReader() io.Reader

type Resolver

+ PTRGet func(string) (string, bool)

+ PTRSet func(string, string)

+ type StdResolver struct

+ ReverseDNSRecord *sync.Map

+ func (r StdResolver) PTRGet(ip string) (string, bool)

+ func (r StdResolver) PTRSet(ip string, domain string)

Aug 8, 2025

Changes in this version

type Conn

+ func (c *Conn) ReadString(delim byte) (string, error)

Aug 8, 2025

Changes in this version

+ var HttpMethods = map[string]struct

type Config

+ Dispatcher Dispatcher

+ HttpHandler HttpHandler

+ Negotiator Negotiator

+ TLSConfig TLSConfig

+ TcpHandler TcpHandler

+ WsHandler WsHandler

type Limiter

+ func NewLimiter(n int64) Limiter

+ type StdLimiter struct

+ func (l *StdLimiter) Acquire()

+ func (l *StdLimiter) Release()

Jun 25, 2025

Changes in this version

type HandshakeFn

+ var Socks5Negotiator HandshakeFn = func(ctx *Context) error { ... }

type RawFilter

+ func (r *RawFilter) Handle(handle RawHandlerFn)

Jun 25, 2025

Changes in this version

+ const CertificatePEM

+ const PrivateKeyPEM

+ var Certificate *x509.Certificate

+ var PrivateKey *rsa.PrivateKey

+ func Debug(args ...any)

+ func Debugf(format string, args ...any)

+ func Error(args ...any)

+ func Errorf(format string, args ...any)

+ func Fatal(args ...any)

+ func Fatalf(format string, args ...any)

+ func Info(args ...any)

+ func Infof(format string, args ...any)

+ func IsDomain(hostname string) bool

+ func ListenAndServe(network, addr string, cfg *Config) error

+ func Panic(args ...any)

+ func Panicf(format string, args ...any)

+ func Serve(inner net.Listener, cfg *Config) error

+ func SetLogLevel(level Level)

+ func Trace(args ...any)

+ func Tracef(format string, args ...any)

+ func Warn(args ...any)

+ func Warnf(format string, args ...any)

+ type Config struct

+ DefaultSAN string

+ func NewConfig() *Config

+ func (c *Config) WithOptions(opts ...ConfigOption) *Config

+ func (c *Config) WithRawMatcher(matcher ...RawMatcher) *RawFilter

+ func (c *Config) WithReqMatcher(matcher ...ReqMatcher) *ReqFilter

+ func (c *Config) WithRespMatcher(matcher ...RespMatcher) *RespFilter

+ func (c *Config) WithWsMatcher(matcher ...WsMatcher) *WsFilter

+ type ConfigOption func(*Config)

+ func WithDialer(dialer Dialer) ConfigOption

+ func WithDispatcher(dispatcher Dispatcher) ConfigOption

+ func WithHttpHandler(httpHandler HttpHandler) ConfigOption

+ func WithLimiter(limiter Limiter) ConfigOption

+ func WithNegotiator(negotiator Negotiator) ConfigOption

+ func WithTLSConfigFn(tlsConfig TLSConfig) ConfigOption

+ func WithTcpHandler(tcpHandler TcpHandler) ConfigOption

+ func WithWsHandler(wsHandler WsHandler) ConfigOption

+ type Conn struct

+ func NewConn(inner net.Conn) *Conn

+ func (c *Conn) Peek(n int) ([]byte, error)

+ func (c *Conn) Read(p []byte) (int, error)

+ type Context struct

+ Conn *Conn

+ DstHost string

+ DstPort string

+ Id string

+ Req *http.Request

+ func NewContext() *Context

+ func (c *Context) Debug(args ...any)

+ func (c *Context) Debugf(format string, args ...any)

+ func (c *Context) Error(args ...any)

+ func (c *Context) Errorf(format string, args ...any)

+ func (c *Context) Fatal(args ...any)

+ func (c *Context) Fatalf(format string, args ...any)

+ func (c *Context) Info(args ...any)

+ func (c *Context) Infof(format string, args ...any)

+ func (c *Context) Panic(args ...any)

+ func (c *Context) Panicf(format string, args ...any)

+ func (c *Context) SetLogLevel(level Level)

+ func (c *Context) SetLogger(logger Logger)

+ func (c *Context) Trace(args ...any)

+ func (c *Context) Tracef(format string, args ...any)

+ func (c *Context) Warn(args ...any)

+ func (c *Context) Warnf(format string, args ...any)

+ type Dialer interface

+ Dial func(string, string, ...DialerOption) (net.Conn, error)

+ WithOptions func(...DialerOption) Dialer

+ func FromURL(proxyURL string, dialer proxy.Dialer) (Dialer, error)

+ type DialerOption func(*dialerConfig)

+ func WithTLSConfig(cfg *tls.Config) DialerOption

+ type DispatchFn func(*Context)

+ func (f DispatchFn) Dispatch(ctx *Context)

+ type Dispatcher interface

+ Dispatch func(*Context)

+ type HandleHttpFn func(*Context)

+ func (f HandleHttpFn) HandleHttp(ctx *Context)

+ type HandleTcpFn func(*Context)

+ func (f HandleTcpFn) HandleTcp(ctx *Context)

+ type HandleWsFn func(*Context)

+ func (f HandleWsFn) HandleWs(ctx *Context)

+ type HandshakeFn func(*Context) error

+ var Socks5Handler HandshakeFn = func(ctx *Context) error { ... }

+ func (f HandshakeFn) Handshake(ctx *Context) error

+ type HttpHandler interface

+ HandleHttp func(*Context)

+ type Level logrus.Level

+ const DebugLevel

+ const ErrorLevel

+ const FatalLevel

+ const InfoLevel

+ const PanicLevel

+ const TraceLevel

+ const WarnLevel

+ type Limiter interface

+ Acquire func()

+ Available func() int

+ Capacity func() int

+ InUse func() int

+ Release func()

+ type Listener struct

+ func Listen(network, addr string, cfg *Config) (*Listener, error)

+ func NewListener(inner net.Listener, cfg *Config) *Listener

+ func (l *Listener) Accept() (net.Conn, error)

+ func (l *Listener) Serve() error

+ type Logger interface

+ Log func(*Context, Level, ...any)

+ Logf func(*Context, Level, string, ...any)

+ SetLevel func(Level)

+ type Logrus struct

+ func (l *Logrus) Log(ctx *Context, level Level, args ...any)

+ func (l *Logrus) Logf(ctx *Context, level Level, format string, args ...any)

+ func (l *Logrus) SetLevel(level Level)

+ type Negotiator interface

+ Handshake func(*Context) error

+ type RawFilter struct

+ func (r *RawFilter) Do(handle RawHandlerFn)

+ type RawHandlerFn func([]byte, *Context) []byte

+ type RawMatchFn func([]byte, *Context) bool

+ func RawHostIs(hosts ...string) RawMatchFn

+ func (f RawMatchFn) Match(raw []byte, ctx *Context) bool

+ type RawMatcher interface

+ Match func(raw []byte, ctx *Context) bool

+ type ReqFilter struct

+ func (r *ReqFilter) Handle(handle ReqHandlerFn)

+ type ReqHandlerFn func(*http.Request, *Context) (*http.Request, *http.Response)

+ type ReqMatchFn func(*http.Request, *Context) bool

+ func Not(matcher ReqMatcher) ReqMatchFn

+ func ReqHostIs(hosts ...string) ReqMatchFn

+ func (f ReqMatchFn) MatchReq(req *http.Request, ctx *Context) bool

+ func (f ReqMatchFn) MatchResp(resp *http.Response, ctx *Context) bool

+ type ReqMatcher interface

+ MatchReq func(*http.Request, *Context) bool

+ type Resolver struct

+ ReverseLookup *sync.Map

+ func NewResolver() *Resolver

+ type RespFilter struct

+ func (r *RespFilter) Handle(handle RespHandlerFn)

+ type RespHandlerFn func(*http.Response, *Context) *http.Response

+ type RespMatchFn func(*http.Response, *Context) bool

+ func StatusCodeIs(codes ...int) RespMatchFn

+ func (f RespMatchFn) MatchResp(resp *http.Response, ctx *Context) bool

+ type RespMatcher interface

+ MatchResp func(*http.Response, *Context) bool

+ type TLSConfig interface

+ From func(string) (*tls.Config, error)

+ type TLSConfigFn func(string) (*tls.Config, error)

+ func From(cert *x509.Certificate, privateKey crypto.PrivateKey) TLSConfigFn

+ func FromCA(cert *x509.Certificate, privateKey *rsa.PrivateKey) TLSConfigFn

+ func FromSelfSigned() TLSConfigFn

+ func (f TLSConfigFn) From(san string) (*tls.Config, error)

+ type TcpHandler interface

+ HandleTcp func(*Context)

+ type TokenBucket struct

+ func NewTokenBucket(max int) *TokenBucket

+ func (tb *TokenBucket) Acquire()

+ func (tb *TokenBucket) Available() int

+ func (tb *TokenBucket) Capacity() int

+ func (tb *TokenBucket) InUse() int

+ func (tb *TokenBucket) Release()

+ type WsFilter struct

+ func (w *WsFilter) Handle(handle WsHandlerFn)

+ type WsHandler interface

+ HandleWs func(*Context)

+ type WsHandlerFn func(ws.Frame, *Context) ws.Frame

+ type WsMatchFn func(ws.Frame, *Context) bool

+ func WsHostIs(hosts ...string) WsMatchFn

+ func (f WsMatchFn) Match(frame ws.Frame, ctx *Context) bool

+ type WsMatcher interface

+ Match func(frame ws.Frame, ctx *Context) bool