recorderproxy

Documentation

Index

• Constants
• 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
  • func (f *ChainedProxyFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type ContextInitFilter
  • func (f *ContextInitFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type DnsLookupFilter
  • func (f *DnsLookupFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type ErrorHandlerFilter
  • func (f *ErrorHandlerFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type NonproxyFilter
  • func (f *NonproxyFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type RecorderFilter
  • func (f *RecorderFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)
• type RecorderProxy
  • func NewRecorderProxy(id int, addr string, port int, conn *serviceconnections.Connections, ...) *RecorderProxy
  • func (proxy *RecorderProxy) Close()
  • func (proxy *RecorderProxy) Dial(context context.Context, isConnect bool, network, addr string) (conn net.Conn, err error)
  • func (proxy *RecorderProxy) Start()
• type TracingInitFilter
  • func (f *TracingInitFilter) Apply(ctx filters.Context, req *http.Request, next filters.Next) (resp *http.Response, context filters.Context, err error)

Constants

const (
	CRLF = "\r\n"
)

Functions

func DecorateRequest

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

func NewConnectReq

func NewConnectReq(addr string) *http.Request

func WrapConn

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

func WrapRequestBody

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

func WrapResponseBody

func WrapResponseBody(ctx filters.Context, body io.ReadCloser, statusCode int32, contentType string,
	recordType contentwriter.RecordType, prolog []byte) (*wrappedResponseBody, error)

Types

type ChainedProxyFilter

type ChainedProxyFilter struct {
	// contains filtered or unexported fields
}

ChainedProxyFilter is a filter which rewrites request to support chained proxies.

func (*ChainedProxyFilter) Apply

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

type ContextInitFilter

type ContextInitFilter struct {
	// contains filtered or unexported fields
}

ContextInitFilter is a filter which initializes the context with sessions to external services.

func (*ContextInitFilter) Apply

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

type DnsLookupFilter

type DnsLookupFilter struct {
	DnsResolverClient dnsresolverV1.DnsResolverClient
}

DnsLookupFilter is a filter which returns an error if the proxy is accessed as if it where a web server and not a proxy.

func (*DnsLookupFilter) Apply

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

type ErrorHandlerFilter

type ErrorHandlerFilter struct {
	// contains filtered or unexported fields
}

ErrorHandlerFilter is a filter which initializes the context with sessions to external services.

func (*ErrorHandlerFilter) Apply

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

type NonproxyFilter

type NonproxyFilter struct{}

NonproxyFilter is a filter which returns an error if the proxy is accessed as if it where a web server and not a proxy.

func (*NonproxyFilter) Apply

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

type RecorderFilter

type RecorderFilter struct {
	DnsResolverClient dnsresolverV1.DnsResolverClient
	// contains filtered or unexported fields
}

RecorderFilter is a filter which returns an error if the proxy is accessed as if it where a web server and not a proxy.

func (*RecorderFilter) Apply

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

type RecorderProxy

type RecorderProxy struct {
	proxy.Proxy

	Addr string

	ConnectionTimeout time.Duration
	// contains filtered or unexported fields
}

func NewRecorderProxy

func NewRecorderProxy(id int, addr string, port int, conn *serviceconnections.Connections, connectionTimeout time.Duration, nextProxyAddr string) *RecorderProxy

func (*RecorderProxy) Close

func (proxy *RecorderProxy) Close()

func (*RecorderProxy) Dial

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

func (*RecorderProxy) Start

func (proxy *RecorderProxy) Start()

type TracingInitFilter

type TracingInitFilter struct{}

TracingInitFilter is a filter which initializes the context with tracing.

func (*TracingInitFilter) Apply

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