gproxy

Sep 16, 2026

Changes in this version

+ func MiddleEndResponseProcessingBytes() int

type MiddleEndFrontendConfig

+ ResponseBudget *middleend.ResponseBudget

type MiddleEndFrontendStats

+ ResponseStallClosures uint64

+ ResponseWaitDurationMicroseconds [middleend.ResponseOutputWaitCount]uint64

+ ResponseWaitsActive [middleend.ResponseOutputWaitCount]int64

+ ResponseWaitsCompletedTotal [middleend.ResponseOutputWaitCount]uint64

+ ResponseWaitsTotal [middleend.ResponseOutputWaitCount]uint64

+ SharedResponseBudget bool

Sep 6, 2026

Changes in this version

+ var ErrLogicalStreamConfig = errors.New("invalid logical MTProxy stream configuration")

type DCConnContext

+ ToClient *relayOutput

+ ToDC *relayOutput

+ type LogicalQueueBudget struct

+ Release func(bytes, items int)

+ Reserve func(bytes, items int) bool

+ type LogicalStream struct

+ func (s *LogicalStream) Close() error

+ func (s *LogicalStream) Discard(n int) (int, error)

+ func (s *LogicalStream) InboundBuffered() int

+ func (s *LogicalStream) LocalAddr() net.Addr

+ func (s *LogicalStream) OutboundBuffered() int

+ func (s *LogicalStream) OwnerStopped()

+ func (s *LogicalStream) Peek(n int) ([]byte, error)

+ func (s *LogicalStream) ReadableBytes() int

+ func (s *LogicalStream) RemoteAddr() net.Addr

+ func (s *LogicalStream) TryRead(dst []byte) (int, error)

+ func (s *LogicalStream) TryWrite(data []byte) (int, error)

+ func (s *LogicalStream) Write(data []byte) (int, error)

+ type LogicalStreamOptions struct

+ ClientAddr netip.AddrPort

+ InputBudget LogicalQueueBudget

+ LocalAddr net.Addr

+ MaxInputBytes int

+ MaxInputItems int

+ MaxOutputBytes int

+ MaxOutputItems int

+ Notify func()

+ OnClosed func(error)

+ OnOpened func(error)

+ OutputBudget LogicalQueueBudget

+ Owner gnet.EventLoop

type ProxyHandler

+ func (h *ProxyHandler) OpenLogicalStream(options LogicalStreamOptions) (*LogicalStream, error)

type RelayContext

+ ToDC *relayOutput

Aug 31, 2026

Changes in this version

+ var ErrInvalidMiddleEndFrontend = errors.New("invalid Middle-End frontend")

+ var ErrMiddleEndClientBackpressure = errors.New("Middle-End client input limit exceeded")

+ var ErrMiddleEndClientProtocol = errors.New("Middle-End client protocol failure")

type Config

+ MaxConnections int

+ MiddleEndFingerprint string

type ConnState

+ const StateMiddleEnd

+ type MiddleEndBindingSource interface

+ BindReady func(middleend.DCID) (*middleend.ClientBinding, error)

+ Done func() <-chan struct{}

+ Ready func() <-chan struct{}

+ TryNextReady func() *middleend.ClientReadyToken

+ type MiddleEndFrontendConfig struct

+ MaxPendingClientBytes int

+ MaxPendingClientBytesTotal int

+ MaxPendingOutputBytesTotal int

+ OutputRetryInitial time.Duration

+ OutputRetryMax time.Duration

+ OutputStallTimeout time.Duration

+ PrecommitFailure MiddleEndPrecommitAction

+ ProxyTag *middleend.ProxyTag

+ Source MiddleEndBindingSource

+ func (MiddleEndFrontendConfig) String() string

+ func (c MiddleEndFrontendConfig) GoString() string

+ type MiddleEndFrontendStats struct

+ DirectFallbacksActive int64

+ DirectFallbacksTotal uint64

+ InputBackpressureEvents uint64

+ InputBytes int64

+ InputBytesHighWater int64

+ InputBytesLimit int64

+ MiddleEndBindingsActive int64

+ MiddleEndBindingsTotal uint64

+ OutputBackpressureEvents uint64

+ OutputBytes int64

+ OutputBytesHighWater int64

+ OutputBytesLimit int64

+ OutputEvictions uint64

+ type MiddleEndPrecommitAction uint8

+ const MiddleEndPrecommitClose

+ const MiddleEndPrecommitDirectFallback

type ProxyHandler

+ func NewProxyHandlerWithMiddleEnd(cfg *Config, logger Logger, frontend MiddleEndFrontendConfig) (*ProxyHandler, error)

+ func RunWithMiddleEnd(cfg *Config, logger Logger, frontend MiddleEndFrontendConfig) (shutdown func(), handler *ProxyHandler, errCh <-chan error, err error)

+ func (h *ProxyHandler) MiddleEndFrontendStats() MiddleEndFrontendStats

Aug 26, 2026

Changes in this version

+ type HandshakeFailureStat struct

+ Stage string

+ Total uint64

type ProxyHandler

+ func (h *ProxyHandler) HandshakeFailureStats() []HandshakeFailureStat

Aug 24, 2026

Changes in this version

type Config

+ InternalProxyAuth *InternalProxyAuth

+ InternalProxyProtocol bool

+ WebProxyFingerprint string

+ type InternalProxyAuth struct

+ func NewInternalProxyAuth() (*InternalProxyAuth, error)

+ func (*InternalProxyAuth) GoString() string

+ func (*InternalProxyAuth) String() string

+ func (a *InternalProxyAuth) AppendPreface(dst []byte) []byte

Jul 23, 2026

Changes in this version

type Config

+ ClientSilenceClose time.Duration

+ ClockSyncURL string

+ FakeCertSize int

+ MaskSNISafelist []string

type ConnContext

+ func (c *ConnContext) SetSpliceOverride(addr string)

type ProxyHandler

+ func (h *ProxyHandler) OnTick() (time.Duration, gnet.Action)

May 23, 2026

Changes in this version

type Config

+ EnableDRS bool

+ EnableSplitTLS bool

Apr 8, 2026

Changes in this version

type Config

+ HandshakeTimeout time.Duration

+ SpliceIdleTimeout time.Duration

type ConnLimiter

+ func (l *ConnLimiter) TryAcquireIP(ip net.IP) (key string, ok bool)

Apr 3, 2026

Changes in this version

type ConnContext

+ func (c *ConnContext) ProtocolMode() ProtocolMode

+ func (c *ConnContext) SetProtocolMode(mode ProtocolMode)

type ConnState

+ const StateDetectProtocol

+ const StateReadDDFrame

+ type ProtocolMode uint8

+ const ModeDD

+ const ModeEE

Apr 1, 2026

Changes in this version

type UserIPStats

+ TrackedIPList []string

+ TrackedIPs int

Mar 27, 2026

Changes in this version

type Config

+ IPBlockTimeout time.Duration

+ MaxIPsPerUser int

type ConnContext

+ func (c *ConnContext) SetTrafficCounters(bytesIn, bytesOut *atomic.Int64)

+ func (c *ConnContext) TrafficIn() *atomic.Int64

+ func (c *ConnContext) TrafficOut() *atomic.Int64

type Logger

+ DebugEnabled func() bool

type ProxyHandler

+ func (h *ProxyHandler) IdleTimeout() time.Duration

+ func (h *ProxyHandler) UserLimiter() *UserIPLimiter

+ type UserIPLimiter struct

+ func NewUserIPLimiter(maxIPsPerUser int, blockTimeout time.Duration) *UserIPLimiter

+ func (l *UserIPLimiter) Close()

+ func (l *UserIPLimiter) LimitingEnabled() bool

+ func (l *UserIPLimiter) Release(key string)

+ func (l *UserIPLimiter) Stats() []UserIPStats

+ func (l *UserIPLimiter) TrafficCounters(secret []byte) (bytesIn, bytesOut *atomic.Int64)

+ func (l *UserIPLimiter) TryAcquire(ip net.IP, secret []byte, secretName string) (key string, ok bool)

+ type UserIPStats struct

+ ActiveIPList []string

+ ActiveIPs int

+ BlockedIPList []string

+ BlockedIPs int

+ BlockedTotal int64

+ BytesIn int64

+ BytesOut int64

+ Connections int64

+ SecretName string

Mar 10, 2026

Changes in this version

+ func CheckFrameSize(size int) bool

+ func Zeroize(b []byte)

+ func ZeroizeArray32(arr *[32]byte)

+ type BufferPool struct

+ func NewBufferPool(size int) *BufferPool

+ func (bp *BufferPool) Get() *[]byte

+ func (bp *BufferPool) Put(buf *[]byte)

type Config

+ MaxWriteBuffer int

type ConnContext

+ func (c *ConnContext) Cleanup()

+ func (c *ConnContext) DCID() int

type DCConnContext

+ DCConn gnet.Conn

+ type DesyncDetector struct

+ func NewDesyncDetector() *DesyncDetector

+ func (d *DesyncDetector) Report(ctx *ConnContext, frameSize int, direction string, logger Logger) bool

+ type HotReloadConfig struct

+ ConfigPath string

+ Handler *ProxyHandler

+ LoadConfig func() (*Config, string, error)

+ Logger Logger

+ SetLogFn func(level string)

+ type HotReloader struct

+ func NewHotReloader(cfg HotReloadConfig) *HotReloader

+ func (r *HotReloader) Start()

+ func (r *HotReloader) Stop()

type ProxyHandler

+ func RunWithHandler(cfg *Config, logger Logger) (shutdown func(), handler *ProxyHandler, errCh <-chan error)

+ func (h *ProxyHandler) ApplyHotConfig(cfg *Config)

type ReplayCache

+ func (c *ReplayCache) Len() int

Mar 3, 2026

Changes in this version

+ func IsUnixSocket(addr string) bool

type Config

+ MaxConnectionsPerIP int

+ ProxyProtocol bool

type ConnContext

+ func (c *ConnContext) ID() uint64

+ func (c *ConnContext) LogPrefix() string

+ func (c *ConnContext) RealClientAddr(fallback net.Addr) net.Addr

+ func (c *ConnContext) SetRealClientAddr(addr net.Addr)

+ type ConnLimiter struct

+ func NewConnLimiter(maxConns int) *ConnLimiter

+ func (l *ConnLimiter) ActiveConnections() int64

+ func (l *ConnLimiter) Release(key string)

+ func (l *ConnLimiter) TryAcquire(ip net.IP, secret []byte) (key string, ok bool)

type ConnState

+ const StateReadProxyProto

+ type ProxyProtoResult struct

+ DstAddr net.Addr

+ HeaderLen int

+ IsLocal bool

+ SrcAddr net.Addr

+ func ParseProxyProtocol(data []byte) (*ProxyProtoResult, error)

Mar 2, 2026

Changes in this version

type Config

+ Socks5Addr string

Feb 27, 2026

Changes in this version

type Config

+ CertHost string

+ CertPort int

+ PprofAddr string

+ SpliceHost string

+ SplicePort int

+ SpliceProxyProtocol int

type ConnContext

+ func (c *ConnContext) SetSpliceConn(conn net.Conn)

+ func (c *ConnContext) SpliceConn() net.Conn

+ type DCConnContext struct

+ ClientConn gnet.Conn

+ ClientCtx *ConnContext

+ ClientEncrypt cipher.Stream

+ DCDecrypt cipher.Stream

+ DCEncrypt cipher.Stream

Feb 24, 2026

Changes in this version

+ func Run(cfg *Config, logger Logger) (shutdown func(), errCh <-chan error)

+ type Config struct

+ BindAddr string

+ CertRefreshHours int

+ FetchRealCert bool

+ Host string

+ IPPreference dc.IPPreference

+ IdleTimeout time.Duration

+ LockOSThread bool

+ MaskHost string

+ MaskPort int

+ Multicore bool

+ NumEventLoop int

+ ReusePort bool

+ Secrets []Secret

+ SpliceUnrecognized bool

+ TimeSkewTolerance time.Duration

+ func DefaultConfig() Config

+ type ConnContext struct

+ func NewConnContext() *ConnContext

+ func (c *ConnContext) Relay() *RelayContext

+ func (c *ConnContext) SetRelay(r *RelayContext)

+ func (c *ConnContext) SetState(state ConnState)

+ func (c *ConnContext) State() ConnState

+ type ConnState int32

+ const StateClosed

+ const StateDialingDC

+ const StateReadO2Frame

+ const StateReadTLSHeader

+ const StateReadTLSPayload

+ const StateRelaying

+ const StateSplicing

+ func (s ConnState) String() string

+ type Logger interface

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

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

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

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

+ type ProxyHandler struct

+ func NewProxyHandler(cfg *Config, logger Logger) *ProxyHandler

+ func (h *ProxyHandler) OnBoot(eng gnet.Engine) gnet.Action

+ func (h *ProxyHandler) OnClose(c gnet.Conn, err error) gnet.Action

+ func (h *ProxyHandler) OnOpen(c gnet.Conn) ([]byte, gnet.Action)

+ func (h *ProxyHandler) OnShutdown(eng gnet.Engine)

+ func (h *ProxyHandler) OnTraffic(c gnet.Conn) gnet.Action

+ type RelayContext struct

+ DCConn net.Conn

+ DCDecrypt cipher.Stream

+ DCEncrypt cipher.Stream

+ Decryptor cipher.Stream

+ Encryptor cipher.Stream

+ type ReplayCache struct

+ func NewReplayCache(maxSize int, ttl time.Duration) *ReplayCache

+ func (c *ReplayCache) Seen(sessionID []byte) bool

+ type Secret struct

+ Host string

+ Key []byte

+ Name string

+ RawHex string