recorderproxy

Apr 23, 2020

Changes in this version

+ func DecorateRequest(roundTripper http.RoundTripper, req *http.Request) (http.RoundTripper, *http.Request)

+ func NewConnectReq(addr string) *http.Request

+ func WrapConn(conn net.Conn, label string, dirOut bool) *wrappedConnection

+ func WrapRequestBody(ctx filters.Context, body io.ReadCloser, contentType string, prolog []byte) (*wrappedRequestBody, error)

+ func WrapResponseBody(ctx filters.Context, body io.ReadCloser, statusCode int32, contentType string, ...) (*wrappedResponseBody, error)

+ type ChainedProxyFilter struct

+ func (f *ChainedProxyFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

+ type ContextInitFilter struct

+ func (f *ContextInitFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

+ type DnsLookupFilter struct

+ DnsResolverClient dnsresolverV1.DnsResolverClient

+ func (f *DnsLookupFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

+ type ErrorHandlerFilter struct

+ func (f *ErrorHandlerFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

+ type NonproxyFilter struct

+ func (f *NonproxyFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

+ type RecorderFilter struct

+ DnsResolverClient dnsresolverV1.DnsResolverClient

+ func (f *RecorderFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

type RecorderProxy

+ Addr string

+ func (proxy *RecorderProxy) Close()

+ func (proxy *RecorderProxy) Dial(context context.Context, isConnect bool, network, addr string) (conn net.Conn, err error)

+ type TracingInitFilter struct

+ func (f *TracingInitFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

Jul 3, 2019

Changes in this version

+ const COLLECTION_ID

+ const CRLF

+ const ContentTypeHtml

+ const ContentTypeText

+ const ENCODING

+ const EXECUTION_ID

+ const JOB_EXECUTION_ID

+ const RECORD_CONTENT_TYPE_REQUEST

+ const RECORD_CONTENT_TYPE_RESPONSE

+ const REQUEST

+ const RESPONSE

+ var RecorderProxyCa tls.Certificate

+ var RecorderProxyCertCache *CertCache

+ var RecorderProxyPrivateKey crypto.Signer

+ var TLSConfig = TLSConfigFromCA()

+ func NewConnections() *connections

+ func NewRecordContext(proxy *RecorderProxy) *recordContext

+ func NewResponse(r *http.Request, contentType string, status int, body string) *http.Response

+ func SetCA(caCertFile, caKeyFile string) error

+ func TLSConfigFromCA() func(host string, ctx *recordContext) (*tls.Config, error)

+ func WrapBody(body io.ReadCloser, bodyType string, ctx *recordContext, recNum int32, ...) (*wrappedBody, error)

+ type CertCache struct

+ func NewCache(lifeWindow time.Duration, maxSizeMb int) (*CertCache, error)

+ func (c *CertCache) Get(host string, ctx *recordContext) (*tls.Certificate, error)

+ func (c *CertCache) Put(host string, derBytes []byte, ctx *recordContext) error

+ type Connections interface

+ BrowserControllerClient func() browsercontrollerV1.BrowserControllerClient

+ Close func()

+ Connect func(contentWriterAddr string, dnsResolverAddr string, browserControllerAddr string, ...) error

+ ContentWriterClient func() contentwriterV1.ContentWriterClient

+ DnsResolverClient func() dnsresolverV1.DnsResolverClient

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ type RecorderProxy struct

+ ConnectDial func(network string, addr string) (net.Conn, error)

+ ConnectionTimeout time.Duration

+ KeepDestinationHeaders bool

+ Logger Logger

+ NonproxyHandler http.Handler

+ RoundTripper *RpRoundTripper

+ Verbose bool

+ func NewRecorderProxy(port int, conn Connections, connectionTimeout time.Duration, cache string) *RecorderProxy

+ func (proxy *RecorderProxy) NewConnectDialToProxy(httpsProxy string) func(network, addr string) (net.Conn, error)

+ func (proxy *RecorderProxy) NewConnectDialToProxyWithHandler(httpsProxy string, connectReqHandler func(req *http.Request)) func(network, addr string) (net.Conn, error)

+ func (proxy *RecorderProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (proxy *RecorderProxy) SetVerbose(v bool)

+ func (proxy *RecorderProxy) Start()

+ type RpRoundTripper struct

+ func NewRpRoundTripper() *RpRoundTripper

+ func (r *RpRoundTripper) RoundTrip(req *http.Request, ctx *recordContext) (response *http.Response, e error)