proxy

Documentation

Index

• Constants
• Variables
• func RemoveHopByHopRequestHeaders(header http.Header)
• func RemoveWebsocketRequestHeaders(header http.Header)
• type Flow
• type HTTPDelegatedInvoker
• type HTTPDelegatedInvokerFunc
  • func (f HTTPDelegatedInvokerFunc) Invoke(r *http.Request) (*http.Response, error)
• type HTTPFlow
  • func (f *HTTPFlow) DumpHTTPRequestView() (*HTTPRequestView, error)
  • func (f *HTTPFlow) DumpHTTPResponseView() (*HTTPResponseView, error)
  • func (f *HTTPFlow) DumpHTTPView() (*HTTPView, error)
• type HTTPRequestView
  • func (v *HTTPRequestView) Encode() []byte
• type HTTPResponseView
  • func (v *HTTPResponseView) Encode() []byte
• type HTTPView
• type ImmutableHTTPInterceptor
• type ImmutableWebsocketInterceptor
• type MimtOption
• type MitmHandler
  • func NewMitmHandler(opt MimtOption) (MitmHandler, error)
• type MutableHTTPInterceptor
• type MutableWebsocketInterceptor
• type ReqContext
• type ReqContextKey
• type WSDirection
• type WSFlow
• type WebsocketDelegatedInvoker
• type WebsocketDelegatedInvokerFunc
  • func (f WebsocketDelegatedInvokerFunc) Invoke(t int, data []byte) error

Constants

const (
	HttpHeaderContentType            = "Content-Type"
	HttpHeaderConnection             = "Connection"
	HttpHeaderKeepAlive              = "Keep-Alive"
	HttpHeaderProxyAuthenticate      = "Proxy-Authenticate"
	HttpHeaderProxyAuthorization     = "Proxy-Authorization"
	HttpHeaderProxyConnection        = "Proxy-Connection"
	HttpHeaderProxyAgent             = "Proxy-Agent"
	HttpHeaderTe                     = "Te"
	HttpHeaderTrailers               = "Trailers"
	HttpHeaderTransferEncoding       = "Transfer-Encoding"
	HttpHeaderUpgrade                = "Upgrade"
	HttpHeaderSecWebsocketKey        = "Sec-Websocket-Key"
	HttpHeaderSecWebsocketVersion    = "Sec-Websocket-Version"
	HttpHeaderSecWebsocketExtensions = "Sec-Websocket-Extensions"
	HttpHeaderContentEncoding        = "Content-Encoding"
	HttpHeaderContentLength          = "Content-Length"
)

Variables

var (
	ReqCtxKey   = ReqContextKey{}
	EmptyReqCtx = ReqContext{}
)

Functions

func RemoveHopByHopRequestHeaders

func RemoveHopByHopRequestHeaders(header http.Header)

func RemoveWebsocketRequestHeaders

func RemoveWebsocketRequestHeaders(header http.Header)

Types

type Flow

type Flow struct {
	FlowID    uint64
	Timestamp int64
	HTTP      *HTTPFlow
	WS        *WSFlow
}

type HTTPDelegatedInvoker

type HTTPDelegatedInvoker interface {
	Invoke(*http.Request) (*http.Response, error)
}

type HTTPDelegatedInvokerFunc

type HTTPDelegatedInvokerFunc func(*http.Request) (*http.Response, error)

func (HTTPDelegatedInvokerFunc) Invoke

func (f HTTPDelegatedInvokerFunc) Invoke(r *http.Request) (*http.Response, error)

type HTTPFlow

type HTTPFlow struct {
	Request  *http.Request
	Response *http.Response
}

func (*HTTPFlow) DumpHTTPRequestView

func (f *HTTPFlow) DumpHTTPRequestView() (*HTTPRequestView, error)

func (*HTTPFlow) DumpHTTPResponseView

func (f *HTTPFlow) DumpHTTPResponseView() (*HTTPResponseView, error)

func (*HTTPFlow) DumpHTTPView

func (f *HTTPFlow) DumpHTTPView() (*HTTPView, error)

type HTTPRequestView

type HTTPRequestView struct {
	Method string
	Uri    string
	Proto  string
	Header http.Header
	Body   []byte
}

func (*HTTPRequestView) Encode

func (v *HTTPRequestView) Encode() []byte

type HTTPResponseView

type HTTPResponseView struct {
	Proto      string
	StatusCode int
	Header     http.Header
	Body       []byte
}

func (*HTTPResponseView) Encode

func (v *HTTPResponseView) Encode() []byte

type HTTPView

type HTTPView struct {
	Request  *HTTPRequestView
	Response *HTTPResponseView
}

type ImmutableHTTPInterceptor

type ImmutableHTTPInterceptor func(*http.Request, *http.Response)

type ImmutableWebsocketInterceptor

type ImmutableWebsocketInterceptor func(WSDirection, *http.Request, int, []byte)

type MimtOption

type MimtOption struct {
	Enable       bool
	Proxy        string
	CaPath       string
	KeyPath      string
	FakeCertPool struct {
		Capacity     int
		Interval     int
		ExpireSecond int
	}
	// contains filtered or unexported fields
}

type MitmHandler

type MitmHandler interface {
	SetMutableHTTPInterceptor(MutableHTTPInterceptor)
	SetImmutableHTTPInterceptor(ImmutableHTTPInterceptor)
	SetMutableWebsocketInterceptor(MutableWebsocketInterceptor)
	SetImmutableWebsocketInterceptor(ImmutableWebsocketInterceptor)
	HandleMIMT(context.Context, net.Conn) error
	CAPath() string
}

func NewMitmHandler

func NewMitmHandler(opt MimtOption) (MitmHandler, error)

type MutableHTTPInterceptor

type MutableHTTPInterceptor func(*http.Request, HTTPDelegatedInvoker) (*http.Response, error)

type MutableWebsocketInterceptor

type MutableWebsocketInterceptor func(WSDirection, *http.Request, int, []byte, WebsocketDelegatedInvoker) error

type ReqContext

type ReqContext struct {
	// Used for http proxy and sock5 (connect) proxy
	ConnMethod bool
	Host       string
	Port       string
	Addr       string
	Request    *http.Request
}

type ReqContextKey

type ReqContextKey struct{}

type WSDirection

type WSDirection byte

const (
	Send WSDirection = iota
	Receive
)

type WSFlow

type WSFlow struct {
	Direction  WSDirection
	Request    *http.Request
	MsgType    int
	FramedData []byte
}

type WebsocketDelegatedInvoker

type WebsocketDelegatedInvoker interface {
	Invoke(int, []byte) error
}

type WebsocketDelegatedInvokerFunc

type WebsocketDelegatedInvokerFunc func(int, []byte) error

func (WebsocketDelegatedInvokerFunc) Invoke

func (f WebsocketDelegatedInvokerFunc) Invoke(t int, data []byte) error