handler

Documentation

Index

• Constants
• 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
  • func (f *Forwarder) ForwardIO(clientConn, backendConn io.ReadWriter) int
• type RequestHandler
  • func NewRequestHandler(request *http.Request, response utils.ProxyResponseWriter, ...) *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

Constants

const (
	MaxRetries = 3
)

Variables

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 SetRequestXCfInstanceId(request *http.Request, endpoint *route.Endpoint)

func SetRequestXRequestStart

func SetRequestXRequestStart(request *http.Request)

Types

type Forwarder

type Forwarder struct {
	BackendReadTimeout time.Duration
	Logger             logger.Logger
}

func (*Forwarder) ForwardIO

func (f *Forwarder) ForwardIO(clientConn, backendConn io.ReadWriter) int

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, endpointDialTimeout time.Duration, tlsConfig *tls.Config, 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