Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HTTPHandler ¶
type HTTPHandler struct {
// contains filtered or unexported fields
}
HTTPHandler process HTTP protocol
func NewHTTPHandler ¶
func NewHTTPHandler( logger *log.Logger, statsdMetrics *statsd.Client, tracingContextMapping *cache.Cache, routingInfoContextMapping *cache.Cache) *HTTPHandler
NewHTTPHandler returns HTTP handler
func (*HTTPHandler) HandleRequest ¶
func (h *HTTPHandler) HandleRequest( r *net.TCPConn, w *net.TCPConn, connCh chan *net.TCPConn, addrCh chan string, netRequest NetRequest, isInboundConn bool, originalDst string) *net.TCPConn
HandleRequest handles HTTP request
func (*HTTPHandler) HandleResponse ¶
func (h *HTTPHandler) HandleResponse(r *net.TCPConn, w *net.TCPConn, netRequest NetRequest, isInboundConn bool, forceClose bool)
type NetHTTPRequest ¶
type NetHTTPRequest struct {
// contains filtered or unexported fields
}
func NewNetHTTPRequest ¶
func NewNetHTTPRequest( logger *log.Logger, isInbound bool, tracingContextMapping *cache.Cache, statsdMetrics *statsd.Client) *NetHTTPRequest
func (*NetHTTPRequest) CleanUp ¶
func (nr *NetHTTPRequest) CleanUp()
func (*NetHTTPRequest) SetHTTPRequest ¶
func (nr *NetHTTPRequest) SetHTTPRequest(r *nhttp.Request)
func (*NetHTTPRequest) SetHTTPResponse ¶
func (nr *NetHTTPRequest) SetHTTPResponse(r *nhttp.Response)
func (*NetHTTPRequest) StartRequest ¶
func (nr *NetHTTPRequest) StartRequest()
func (*NetHTTPRequest) StopRequest ¶
func (nr *NetHTTPRequest) StopRequest()
type NetHandler ¶
type NetHandler interface {
// HandleRequest should get all data from r, process it and write result to w
HandleRequest(
r *net.TCPConn,
w *net.TCPConn,
connCh chan *net.TCPConn,
addrCh chan string,
netRequest NetRequest,
isInboundConn bool,
originalDst string) *net.TCPConn
// HandleResponse should get all data from r, process it and write result to w
HandleResponse(r *net.TCPConn, w *net.TCPConn, netRequest NetRequest, isInboundConn bool, forceClose bool)
}
func GetNetworkHandler ¶
func GetNetworkHandler( proto Proto, logger *log.Logger, tracingContextMapping *cache.Cache) NetHandler
type NetRequest ¶
type NetRequest interface {
StartRequest()
StopRequest()
CleanUp()
}
func GetNetRequest ¶
type NetTCPRequest ¶
type NetTCPRequest struct {
}
func NewNetTCPRequest ¶
func NewNetTCPRequest(logger *log.Logger) *NetTCPRequest
func (*NetTCPRequest) CleanUp ¶
func (r *NetTCPRequest) CleanUp()
func (*NetTCPRequest) StartRequest ¶
func (r *NetTCPRequest) StartRequest()
func (*NetTCPRequest) StopRequest ¶
func (r *NetTCPRequest) StopRequest()
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue implements queue data structure
type TCPHandler ¶
type TCPHandler struct {
// contains filtered or unexported fields
}
func NewTCPHandler ¶
func NewTCPHandler(logger *log.Logger) *TCPHandler
func (*TCPHandler) HandleRequest ¶
func (*TCPHandler) HandleResponse ¶
func (h *TCPHandler) HandleResponse(r *net.TCPConn, w *net.TCPConn, netRequest NetRequest, isInboundConn bool, forceClose bool)
type TempWriter ¶
type TempWriter struct {
// contains filtered or unexported fields
}
TempWriter allows write to temp buffer and retrieve it in case we need it
func NewTempWriter ¶
func NewTempWriter() *TempWriter
NewTempWriter creates new instance of TempWriter
Source Files
Click to show internal directories.
Click to hide internal directories.