Documentation ¶
Index ¶
- Constants
- Variables
- func SetRequestXCfInstanceId(request *http.Request, endpoint *route.Endpoint)
- func SetRequestXRequestStart(request *http.Request)
- type RequestHandler
- func (h *RequestHandler) AddLoggingData(data lager.Data)
- func (h *RequestHandler) HandleBadGateway(err error, request *http.Request)
- func (h *RequestHandler) HandleBadSignature(err error)
- func (h *RequestHandler) HandleHeartbeat(ok bool)
- func (h *RequestHandler) HandleMissingRoute()
- func (h *RequestHandler) HandleRouteServiceFailure(err error)
- func (h *RequestHandler) HandleTcpRequest(iter route.EndpointIterator)
- func (h *RequestHandler) HandleUnsupportedProtocol()
- func (h *RequestHandler) HandleUnsupportedRouteService()
- func (h *RequestHandler) HandleWebSocketRequest(iter route.EndpointIterator)
- func (h *RequestHandler) Logger() lager.Logger
Constants ¶
View Source
const (
MaxRetries = 3
)
Variables ¶
View Source
var NoEndpointsAvailable = errors.New("No endpoints available")
Functions ¶
func SetRequestXCfInstanceId ¶
func SetRequestXRequestStart ¶
Types ¶
type RequestHandler ¶
type RequestHandler struct {
// contains filtered or unexported fields
}
func NewRequestHandler ¶
func NewRequestHandler(request *http.Request, response utils.ProxyResponseWriter, r reporter.ProxyReporter, alr *schema.AccessLogRecord, logger lager.Logger) *RequestHandler
func (*RequestHandler) AddLoggingData ¶
func (h *RequestHandler) AddLoggingData(data lager.Data)
func (*RequestHandler) HandleBadGateway ¶
func (h *RequestHandler) HandleBadGateway(err error, request *http.Request)
func (*RequestHandler) HandleBadSignature ¶
func (h *RequestHandler) HandleBadSignature(err error)
func (*RequestHandler) HandleHeartbeat ¶
func (h *RequestHandler) HandleHeartbeat(ok bool)
func (*RequestHandler) HandleMissingRoute ¶
func (h *RequestHandler) HandleMissingRoute()
func (*RequestHandler) HandleRouteServiceFailure ¶
func (h *RequestHandler) HandleRouteServiceFailure(err error)
func (*RequestHandler) HandleTcpRequest ¶
func (h *RequestHandler) HandleTcpRequest(iter route.EndpointIterator)
func (*RequestHandler) HandleUnsupportedProtocol ¶
func (h *RequestHandler) HandleUnsupportedProtocol()
func (*RequestHandler) HandleUnsupportedRouteService ¶
func (h *RequestHandler) HandleUnsupportedRouteService()
func (*RequestHandler) HandleWebSocketRequest ¶
func (h *RequestHandler) HandleWebSocketRequest(iter route.EndpointIterator)
func (*RequestHandler) Logger ¶
func (h *RequestHandler) Logger() lager.Logger
Click to show internal directories.
Click to hide internal directories.