martian

Jul 25, 2022

Changes in this version

type IdleTimeoutConn

+ TsRenew int64

+ func (c *IdleTimeoutConn) CleanConnJob()

+ func (c *IdleTimeoutConn) GetTsRenew() int64

Jul 17, 2022

Changes in this version

+ var AP *ants.Pool

+ func APSubmit(f func())

+ func GetAP() *ants.Pool

Jul 12, 2022

Changes in this version

+ var AntsPool *ants.Pool

Jul 7, 2022

Changes in this version

+ const MaxRetries

+ const RetryAfterTime

Jul 3, 2022

Changes in this version

+ var DefaultBufSize = 131072

Jun 11, 2022

Changes in this version

type IdleTimeoutConn

+ LastTs int64

May 28, 2022

Changes in this version

type IdleTimeoutConn

+ func (self IdleTimeoutConn) UpdateIdleTime(Conn net.Conn, t time.Time)

May 28, 2022

Changes in this version

+ var DefaultProxyIdleTimeout = 1 * time.Minute

+ var IdleTimeSub = -10 * time.Second

type IdleTimeoutConn

+ LastReadIdleTime time.Time

+ LastWriteIdleTime time.Time

May 28, 2022

Changes in this version

type IdleTimeoutConn

+ Cbr *bufio.Reader

+ Cbw *bufio.Writer

+ func (self IdleTimeoutConn) Flush()

May 28, 2022

Changes in this version

+ var ProxyIdleTimeout = 1 * time.Minute

+ func Init()

+ type Context struct

+ func NewContext(req *http.Request) *Context

+ func TestContext(req *http.Request, conn net.Conn, bw *bufio.ReadWriter) (ctx *Context, remove func(), err error)

+ func (ctx *Context) APIRequest()

+ func (ctx *Context) Get(key string) (interface{}, bool)

+ func (ctx *Context) ID() string

+ func (ctx *Context) IsAPIRequest() bool

+ func (ctx *Context) Session() *Session

+ func (ctx *Context) Set(key string, val interface{})

+ func (ctx *Context) SkipLogging()

+ func (ctx *Context) SkipRoundTrip()

+ func (ctx *Context) SkippingLogging() bool

+ func (ctx *Context) SkippingRoundTrip() bool

+ type IdleTimeoutConn struct

+ Conn net.Conn

+ func (self IdleTimeoutConn) Read(buf []byte) (int, error)

+ func (self IdleTimeoutConn) Write(buf []byte) (int, error)

+ type MultiError struct

+ func NewMultiError() *MultiError

+ func (merr *MultiError) Add(err error)

+ func (merr *MultiError) Empty() bool

+ func (merr *MultiError) Error() string

+ func (merr *MultiError) Errors() []error

+ type Proxy struct

+ func NewProxy() *Proxy

+ func (p *Proxy) Close()

+ func (p *Proxy) Closing() bool

+ func (p *Proxy) GetRoundTripper() http.RoundTripper

+ func (p *Proxy) Serve(l net.Listener) error

+ func (p *Proxy) SetDial(dial func(string, string) (net.Conn, error))

+ func (p *Proxy) SetDownstreamProxy(proxyURL *url.URL)

+ func (p *Proxy) SetMITM(config *mitm.Config)

+ func (p *Proxy) SetRequestModifier(reqmod RequestModifier)

+ func (p *Proxy) SetResponseModifier(resmod ResponseModifier)

+ func (p *Proxy) SetRoundTripper(rt http.RoundTripper)

+ func (p *Proxy) SetTimeout(timeout time.Duration)

+ type RequestModifier interface

+ ModifyRequest func(req *http.Request) error

+ type RequestModifierFunc func(req *http.Request) error

+ func (f RequestModifierFunc) ModifyRequest(req *http.Request) error

+ type RequestResponseModifier interface

+ func Noop(id string) RequestResponseModifier

+ type ResponseModifier interface

+ ModifyResponse func(res *http.Response) error

+ type ResponseModifierFunc func(res *http.Response) error

+ func (f ResponseModifierFunc) ModifyResponse(res *http.Response) error

+ type Session struct

+ func (s *Session) Get(key string) (interface{}, bool)

+ func (s *Session) Hijack() (net.Conn, *bufio.ReadWriter, error)

+ func (s *Session) Hijacked() bool

+ func (s *Session) ID() string

+ func (s *Session) IsSecure() bool

+ func (s *Session) MarkInsecure()

+ func (s *Session) MarkSecure()

+ func (s *Session) Set(key string, val interface{})