Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proxy

package

Go to main page

Versions in this module

v1

v1.4.8

Jan 19, 2021

v1.4.4

Jan 13, 2021

Changes in this version

+ func CloneBody(b io.ReadCloser) (r io.ReadCloser, body []byte, err error)

+ func CloneHeader(h http.Header) http.Header

+ func CopyHeader(dst, src http.Header)

type Context

+ Data map[interface{}]interface{}

+ func (c *Context) Abort()

+ func (c *Context) IsAborted() bool

+ type DefaultDelegate struct

+ func (h *DefaultDelegate) Auth(ctx *Context, rw http.ResponseWriter)

+ func (h *DefaultDelegate) BeforeRequest(ctx *Context)

+ func (h *DefaultDelegate) BeforeResponse(ctx *Context, resp *http.Response, err error)

+ func (h *DefaultDelegate) Connect(ctx *Context, rw http.ResponseWriter)

+ func (h *DefaultDelegate) ErrorLog(err error)

+ func (h *DefaultDelegate) Finish(ctx *Context)

+ type Delegate interface

+ Auth func(ctx *Context, rw http.ResponseWriter)

+ BeforeRequest func(ctx *Context)

+ BeforeResponse func(ctx *Context, resp *http.Response, err error)

+ Connect func(ctx *Context, rw http.ResponseWriter)

+ ErrorLog func(err error)

+ Finish func(ctx *Context)

+ type Option func(*options)

+ func WithDecryptHTTPS(c cert.Cache) Option

+ func WithDelegate(delegate Delegate) Option

+ func WithDisableKeepAlive(disableKeepAlive bool) Option

+ func WithTransport(t *http.Transport) Option

type Proxy

+ func New(opt ...Option) *Proxy

+ func (p *Proxy) ClientConnNum() int32

+ func (p *Proxy) DoRequest(ctx *Context, responseFunc func(*http.Response, error))

v1.4.3

Jan 13, 2021

Changes in this version

+ const ConnectMitm

+ const ConnectNone

+ const ConnectProxy

+ var DefaultCaCert = []byte(...)

+ var DefaultCaKey = []byte(...)

+ var ErrAbsURLAfterCONNECT = NewError("absolute URL after CONNECT")

+ var ErrNotSupportHTTPVer = NewError("http version not supported")

+ var ErrNotSupportHijacking = NewError("hijacking not supported")

+ var ErrPanic = NewError("panic")

+ var ErrRemoteConnect = NewError("remote connect")

+ var ErrRequestRead = NewError("request read")

+ var ErrResponseWrite = NewError("response write")

+ var ErrRoundTrip = NewError("round trip")

+ var ErrTLSHandshake = NewError("TLS handshake")

+ var ErrTLSSignHost = NewError("TLS sign host")

+ var ErrUnsupportedTransferEncoding = NewError("unsupported transfer encoding")

+ func InMemoryResponse(code int, header http.Header, body []byte) *http.Response

+ func ServeInMemory(w http.ResponseWriter, code int, header http.Header, body []byte) error

+ func ServeResponse(w http.ResponseWriter, resp *http.Response) error

+ func SignHosts(ca tls.Certificate, hosts []string) (*tls.Certificate, error)

+ type CaSigner struct

+ Ca *tls.Certificate

+ func NewCaSigner() *CaSigner

+ func NewCaSignerCache(max int) *CaSigner

+ func (c *CaSigner) SignHost(host string) (cert *tls.Certificate)

+ type Config struct

+ Host string

+ Name string

+ Network string

+ Port int

+ Proxy *Proxy

+ func (config *Config) Address() string

+ func (config *Config) Build() *Server

+ func (config *Config) WithHost(host string) *Config

+ func (config *Config) WithName(name string) *Config

+ func (config *Config) WithPort(port int) *Config

+ func (config *Config) WithProxy(proxy *Proxy) *Config

+ type ConnResponseWriter struct

+ Conn net.Conn

+ func NewConnResponseWriter(conn net.Conn) *ConnResponseWriter

+ func (c *ConnResponseWriter) Close() error

+ func (c *ConnResponseWriter) Header() http.Header

+ func (c *ConnResponseWriter) Write(body []byte) (int, error)

+ func (c *ConnResponseWriter) WriteHeader(statusCode int)

+ type ConnectAction int

+ type Context struct

+ ConnectAction ConnectAction

+ ConnectHost string

+ ConnectReq *http.Request

+ Prx *Proxy

+ Req *http.Request

+ SessionNo int64

+ SubSessionNo int64

+ UserData interface{}

+ type Error struct

+ ErrString string

+ func NewError(errString string) *Error

+ func (e *Error) Error() string

+ type Proxy struct

+ AuthType string

+ Ca tls.Certificate

+ MitmChunked bool

+ OnAccept func(ctx *Context, w http.ResponseWriter, r *http.Request) bool

+ OnAuth func(ctx *Context, authType string, user string, pass string) bool

+ OnConnect func(ctx *Context, host string) (ConnectAction ConnectAction, newHost string)

+ OnError func(ctx *Context, where string, err *Error, opErr error)

+ OnRequest func(ctx *Context, req *http.Request) (resp *http.Response)

+ OnResponse func(ctx *Context, req *http.Request, resp *http.Response)

+ Rt http.RoundTripper

+ SessionNo int64

+ UserData interface{}

+ func NewProxy() (*Proxy, error)

+ func NewProxyCert(caCert, caKey []byte) (*Proxy, error)

+ func (prx *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Server struct

+ Server *http.Server

+ func (s *Server) GracefulStop(ctx context.Context) error

+ func (s *Server) Info() *server.ServiceInfo

+ func (s *Server) Serve() error

+ func (s *Server) Stop() error