proxy

May 20, 2024

Changes in this version

type ClientConn

+ NegotiatedProtocol string

+ type UpstreamCertAddon struct

+ UpstreamCert bool

+ func NewUpstreamCertAddon(upstreamCert bool) *UpstreamCertAddon

+ func (addon *UpstreamCertAddon) ClientConnected(conn *ClientConn)

Sep 4, 2023

Changes in this version

type ClientConn

+ UpstreamCert bool

Jul 19, 2023

Changes in this version

type Proxy

+ func (proxy *Proxy) SetUpstreamProxy(fn func(req *http.Request) (*url.URL, error))

Jul 18, 2023

Changes in this version

type Addon

+ AccessProxyServer func(req *http.Request, res http.ResponseWriter)

type BaseAddon

+ func (addon *BaseAddon) AccessProxyServer(req *http.Request, res http.ResponseWriter)

Mar 8, 2023

Changes in this version

+ func NewStructFromFile(filename string) (*T, error)

type Flow

+ UseSeparateClient bool

Feb 13, 2023

Changes in this version

type ConnContext

+ FlowCount uint32

+ Intercept bool

Jan 17, 2023

Changes in this version

type Proxy

+ func (proxy *Proxy) GetCertificate() x509.Certificate

+ func (proxy *Proxy) SetShouldInterceptRule(rule func(address string) bool)

Oct 4, 2022

Changes in this version

type Options

+ Upstream string

Jul 7, 2022

Changes in this version

type Proxy

+ func (proxy *Proxy) Close() error

+ func (proxy *Proxy) Shutdown(ctx context.Context) error

Jun 30, 2022

Changes in this version

type Addon

+ StreamRequestModifier func(*Flow, io.Reader) io.Reader

+ StreamResponseModifier func(*Flow, io.Reader) io.Reader

type BaseAddon

+ func (addon *BaseAddon) StreamRequestModifier(f *Flow, in io.Reader) io.Reader

+ func (addon *BaseAddon) StreamResponseModifier(f *Flow, in io.Reader) io.Reader

type Response

+ BodyReader io.Reader

Jun 26, 2022

Changes in this version

+ type Addon interface

+ ClientConnected func(*ClientConn)

+ ClientDisconnected func(*ClientConn)

+ Request func(*Flow)

+ Requestheaders func(*Flow)

+ Response func(*Flow)

+ Responseheaders func(*Flow)

+ ServerConnected func(*ConnContext)

+ ServerDisconnected func(*ConnContext)

+ TlsEstablishedServer func(*ConnContext)

+ type BaseAddon struct

+ func (addon *BaseAddon) ClientConnected(*ClientConn)

+ func (addon *BaseAddon) ClientDisconnected(*ClientConn)

+ func (addon *BaseAddon) Request(*Flow)

+ func (addon *BaseAddon) Requestheaders(*Flow)

+ func (addon *BaseAddon) Response(*Flow)

+ func (addon *BaseAddon) Responseheaders(*Flow)

+ func (addon *BaseAddon) ServerConnected(*ConnContext)

+ func (addon *BaseAddon) ServerDisconnected(*ConnContext)

+ func (addon *BaseAddon) TlsEstablishedServer(*ConnContext)

+ type ClientConn struct

+ Conn net.Conn

+ Id uuid.UUID

+ Tls bool

+ func (c *ClientConn) MarshalJSON() ([]byte, error)

+ type ConnContext struct

+ ClientConn *ClientConn

+ ServerConn *ServerConn

+ func (connCtx *ConnContext) Id() uuid.UUID

+ type Flow struct

+ ConnContext *ConnContext

+ Id uuid.UUID

+ Request *Request

+ Response *Response

+ Stream bool

+ func (f *Flow) Done() <-chan struct{}

+ func (f *Flow) MarshalJSON() ([]byte, error)

+ type LogAddon struct

+ func (addon *LogAddon) ClientConnected(client *ClientConn)

+ func (addon *LogAddon) ClientDisconnected(client *ClientConn)

+ func (addon *LogAddon) Requestheaders(f *Flow)

+ func (addon *LogAddon) ServerConnected(connCtx *ConnContext)

+ func (addon *LogAddon) ServerDisconnected(connCtx *ConnContext)

type Options

+ Debug int

type Proxy

+ Opts *Options

+ type Request struct

+ Body []byte

+ Header http.Header

+ Method string

+ Proto string

+ URL *url.URL

+ func (r *Request) Raw() *http.Request

+ func (req *Request) MarshalJSON() ([]byte, error)

+ func (req *Request) UnmarshalJSON(data []byte) error

+ type Response struct

+ Body []byte

+ Header http.Header

+ StatusCode int

+ func (r *Response) DecodedBody() ([]byte, error)

+ func (r *Response) IsTextContentType() bool

+ func (r *Response) ReplaceToDecodedBody()

+ type ServerConn struct

+ Address string

+ Conn net.Conn

+ Id uuid.UUID

+ func (c *ServerConn) MarshalJSON() ([]byte, error)

+ func (c *ServerConn) TlsState() *tls.ConnectionState

Mar 8, 2022

Changes in this version

type Options

+ CaRootPath string

Jan 20, 2022

Changes in this version

type Proxy

+ Version string

Jan 14, 2022

Changes in this version

type Options

+ SslInsecure bool

Nov 17, 2021

Changes in this version

+ var NormalErrMsgs []string = []string

+ func GetTlsKeyLogWriter() io.Writer

+ func LogErr(log *_log.Entry, err error) (loged bool)

+ func ReaderToBuffer(r io.Reader, limit int64) ([]byte, io.Reader, error)

+ func Transfer(log *_log.Entry, a, b io.ReadWriteCloser)

+ type Forward struct

+ func (i *Forward) Dial(host string) (net.Conn, error)

+ func (i *Forward) Start() error

+ type Interceptor interface

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

+ Start func() error

+ func NewMiddle(proxy *Proxy) (Interceptor, error)

+ type Middle struct

+ CA *cert.CA

+ Listener net.Listener

+ Proxy *Proxy

+ Server *http.Server

+ func (m *Middle) Dial(host string) (net.Conn, error)

+ func (m *Middle) ServeHTTP(res http.ResponseWriter, req *http.Request)

+ func (m *Middle) Start() error

+ type Options struct

+ Addr string

+ StreamLargeBodies int64

+ type Proxy struct

+ Addons []addon.Addon

+ Client *http.Client

+ Interceptor Interceptor

+ Server *http.Server

+ StreamLargeBodies int64

+ func NewProxy(opts *Options) (*Proxy, error)

+ func (proxy *Proxy) AddAddon(addon addon.Addon)

+ func (proxy *Proxy) ServeHTTP(res http.ResponseWriter, req *http.Request)

+ func (proxy *Proxy) Start() error

+ type WebSocket struct

+ var DefaultWebSocket WebSocket

+ func (s *WebSocket) WS(conn net.Conn, host string)

+ func (s *WebSocket) WSS(res http.ResponseWriter, req *http.Request)