raksh

type HttpApplication interface {
	RequestDataHandler(flow *HttpFlow, data []byte) ([]byte, error)
	ResponseDataHandler(flow *HttpFlow, data []byte) ([]byte, error)
	RequestHandler(flow *HttpFlow) error
	ResponseHandler(flow *HttpFlow) error
	StreamedRequestDataHandler(flow *HttpFlow, buf []byte, last_chunk bool) ([]byte, error)
	StreamedResponseDataHandler(flow *HttpFlow, buf []byte, last_chunk bool) ([]byte, error)
	FailureHandler(flow *HttpFlow)
}

type HttpFlow struct {
	Id                string
	Request           *http.Request
	Response          *http.Response
	RequestStreaming  bool
	ResponseStreaming bool
}

type HttpMitmProxy struct {
	// The transport used to perform proxy requests.
	// If nil, http.DefaultTransport is used
	Transport StreamingTransport

	// BufferPool specifies a buffer pool to get byte slices for use by
	// io.CopyBuffer when copying HTTP request and response bodies
	BufferPool *bpool.BytePool

	ChunkSize int64
	// contains filtered or unexported fields
}

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

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

type StreamingTransport interface {
	// A StreamingTransport provides support to stream HTTP requests
	// and responses to a server, optionally re-using connections
	// to ship multiple http transactions
	//
	// It should not attempt to intrepret the response or modify the
	// request.
	// The Request's URL and Header fields are expected to be initialized
	GetConnection(req *http.Request) (*PersistConn, error)
	PutConnection(pconn *PersistConn) error

	WriteHeader(pconn *PersistConn, req *http.Request) error
	Write(pconn *PersistConn, req *http.Request, src []byte) (int, error)

	ReadResponse(pconn *PersistConn, req *http.Request) (resp *http.Response, err error)
	ClientClose(remote string)
}