Documentation
¶
Index ¶
- Variables
- func DisableSourceIPLogging(t bool) func(*RequestHandler)
- func DisableXFFLogging(t bool) func(*RequestHandler)
- func SetRequestXCfInstanceId(request *http.Request, endpoint *route.Endpoint)
- func SetRequestXRequestStart(request *http.Request)
- type Forwarder
- type RequestHandler
- func (h *RequestHandler) HandleBadGateway(err error, request *http.Request)
- func (h *RequestHandler) HandleTcpRequest(iter route.EndpointIterator)
- func (h *RequestHandler) HandleWebSocketRequest(iter route.EndpointIterator)
- func (h *RequestHandler) Logger() logger.Logger
- func (h *RequestHandler) SanitizeRequestConnection()
Constants ¶
This section is empty.
Variables ¶
View Source
var NoEndpointsAvailable = errors.New("No endpoints available")
Functions ¶
func DisableSourceIPLogging ¶
func DisableSourceIPLogging(t bool) func(*RequestHandler)
func DisableXFFLogging ¶
func DisableXFFLogging(t bool) func(*RequestHandler)
func SetRequestXCfInstanceId ¶
func SetRequestXRequestStart ¶
Types ¶
type Forwarder ¶
func (*Forwarder) ForwardIO ¶
func (f *Forwarder) ForwardIO(clientConn, backendConn io.ReadWriter) (int, error)
ForwardIO sets up websocket forwarding with a backend
It returns after one of the connections closes.
If the backend response code is not 101 Switching Protocols, then ForwardIO will return immediately, allowing the caller to close the connections.
type RequestHandler ¶
type RequestHandler struct {
// contains filtered or unexported fields
}
func NewRequestHandler ¶
func NewRequestHandler( request *http.Request, response utils.ProxyResponseWriter, r metrics.ProxyReporter, logger logger.Logger, errorWriter errorwriter.ErrorWriter, endpointDialTimeout time.Duration, websocketDialTimeout time.Duration, maxAttempts int, tlsConfig *tls.Config, hopByHopHeadersToFilter []string, opts ...func(*RequestHandler), ) *RequestHandler
func (*RequestHandler) HandleBadGateway ¶
func (h *RequestHandler) HandleBadGateway(err error, request *http.Request)
func (*RequestHandler) HandleTcpRequest ¶
func (h *RequestHandler) HandleTcpRequest(iter route.EndpointIterator)
func (*RequestHandler) HandleWebSocketRequest ¶
func (h *RequestHandler) HandleWebSocketRequest(iter route.EndpointIterator)
func (*RequestHandler) Logger ¶
func (h *RequestHandler) Logger() logger.Logger
func (*RequestHandler) SanitizeRequestConnection ¶
func (h *RequestHandler) SanitizeRequestConnection()
Source Files
Click to show internal directories.
Click to hide internal directories.