proxy

Documentation

Index

• Constants
• func NewProxyResponseWriter(w http.ResponseWriter) *proxyResponseWriter
• func NewProxyRoundTripper(backend bool, transport http.RoundTripper, ...) http.RoundTripper
• func SetupProxyRequest(source *http.Request, target *http.Request, ...)
• type AfterRoundTrip
• type BackendRoundTripper
  • func (rt *BackendRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)
• type LookupRegistry
• type Proxy
  • func NewProxy(args ProxyArgs) Proxy
• type ProxyArgs
• type ProxyReporter
• type ProxyResponseWriter
• type RequestHandler
  • func NewRequestHandler(request *http.Request, response ProxyResponseWriter, r ProxyReporter, ...) RequestHandler
  • func (h *RequestHandler) HandleBadGateway(err error)
  • func (h *RequestHandler) HandleBadSignature(err error)
  • func (h *RequestHandler) HandleHeartbeat()
  • 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() *steno.Logger
• type RouteServiceRoundTripper
  • func (rt *RouteServiceRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

Constants

const (
	VcapCookieId    = "__VCAP_ID__"
	StickyCookieKey = "JSESSIONID"
)

Functions

func NewProxyResponseWriter

func NewProxyResponseWriter(w http.ResponseWriter) *proxyResponseWriter

func NewProxyRoundTripper

func NewProxyRoundTripper(backend bool, transport http.RoundTripper, endpointIterator route.EndpointIterator,
	handler RequestHandler, afterRoundTrip AfterRoundTrip) http.RoundTripper

func SetupProxyRequest

func SetupProxyRequest(source *http.Request, target *http.Request,
	routeServiceArgs route_service.RouteServiceArgs,
	routeServiceConfig *route_service.RouteServiceConfig)

Types

type AfterRoundTrip

type AfterRoundTrip func(rsp *http.Response, endpoint *route.Endpoint, err error)

type BackendRoundTripper

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

func (*BackendRoundTripper) RoundTrip

func (rt *BackendRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

type LookupRegistry

type LookupRegistry interface {
	Lookup(uri route.Uri) *route.Pool
}

type Proxy

type Proxy interface {
	ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)
}

func NewProxy

func NewProxy(args ProxyArgs) Proxy

type ProxyArgs

type ProxyArgs struct {
	EndpointTimeout     time.Duration
	Ip                  string
	TraceKey            string
	Registry            LookupRegistry
	Reporter            ProxyReporter
	AccessLogger        access_log.AccessLogger
	SecureCookies       bool
	TLSConfig           *tls.Config
	RouteServiceEnabled bool
	RouteServiceTimeout time.Duration
	Crypto              secure.Crypto
	CryptoPrev          secure.Crypto
	ExtraHeadersToLog   []string
}

type ProxyReporter

type ProxyReporter interface {
	CaptureBadRequest(req *http.Request)
	CaptureBadGateway(req *http.Request)
	CaptureRoutingRequest(b *route.Endpoint, req *http.Request)
	CaptureRoutingResponse(b *route.Endpoint, res *http.Response, t time.Time, d time.Duration)
}

type ProxyResponseWriter

type ProxyResponseWriter interface {
	Header() http.Header
	Hijack() (net.Conn, *bufio.ReadWriter, error)
	Write(b []byte) (int, error)
	WriteHeader(s int)
	Done()
	Flush()
	Status() int
	Size() int
}

type RequestHandler

type RequestHandler struct {
	StenoLogger *steno.Logger
	// contains filtered or unexported fields
}

func NewRequestHandler

func NewRequestHandler(request *http.Request, response ProxyResponseWriter, r ProxyReporter,
	alr *access_log.AccessLogRecord) RequestHandler

func (*RequestHandler) HandleBadGateway

func (h *RequestHandler) HandleBadGateway(err error)

func (*RequestHandler) HandleBadSignature

func (h *RequestHandler) HandleBadSignature(err error)

func (*RequestHandler) HandleHeartbeat

func (h *RequestHandler) HandleHeartbeat()

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() *steno.Logger

type RouteServiceRoundTripper

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

func (*RouteServiceRoundTripper) RoundTrip

func (rt *RouteServiceRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)