Documentation
¶
Overview ¶
Package proxy provides transport and upgrade support for proxies.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var MirrorRequest http.RoundTripper = onewayRoundTripper{}
MirrorRequest is a round tripper that can be called to get back the calling request as the core round tripper in a chain.
Functions ¶
func DialURL ¶
DialURL will dial the specified URL using the underlying dialer held by the passed RoundTripper. The primary use of this method is to support proxying upgradable connections. For this reason this method will prefer to negotiate http/1.1 if the URL scheme is https. If you wish to ensure ALPN negotiates http2 then set NextProto=[]string{"http2"} in the TLSConfig of the http.Transport
Types ¶
type ErrorResponder ¶
type ErrorResponder interface {
Error(w http.ResponseWriter, req *http.Request, err error)
}
ErrorResponder abstracts error reporting to the proxy handler to remove the need to hardcode a particular error format.
func NewErrorResponder ¶
func NewErrorResponder(r SimpleErrorResponder) ErrorResponder
type SimpleErrorResponder ¶
type SimpleErrorResponder interface {
Error(err error)
}
SimpleErrorResponder is the legacy implementation of ErrorResponder for callers that only service a single request/response per proxy.
type Transport ¶
type Transport struct {
Scheme string
Host string
PathPrepend string
http.RoundTripper
}
Transport is a transport for text/html content that replaces URLs in html content with the prefix of the proxy server
func (*Transport) WrappedRoundTripper ¶
func (rt *Transport) WrappedRoundTripper() http.RoundTripper
type UpgradeAwareHandler ¶
type UpgradeAwareHandler struct {
// UpgradeRequired will reject non-upgrade connections if true.
UpgradeRequired bool
// Location is the location of the upstream proxy. It is used as the location to Dial on the upstream server
// for upgrade requests unless UseRequestLocationOnUpgrade is true.
Location *url.URL
// AppendLocationPath determines if the original path of the Location should be appended to the upstream proxy request path
AppendLocationPath bool
// Transport provides an optional round tripper to use to proxy. If nil, the default proxy transport is used
Transport http.RoundTripper
// UpgradeTransport, if specified, will be used as the backend transport when upgrade requests are provided.
// This allows clients to disable HTTP/2.
UpgradeTransport UpgradeRequestRoundTripper
// WrapTransport indicates whether the provided Transport should be wrapped with default proxy transport behavior (URL rewriting, X-Forwarded-* header setting)
WrapTransport bool
// UseRequestLocation will use the incoming request URL when talking to the backend server.
UseRequestLocation bool
// UseLocationHost overrides the HTTP host header in requests to the backend server to use the Host from Location.
// This will override the req.Host field of a request, while UseRequestLocation will override the req.URL field
// of a request. The req.URL.Host specifies the server to connect to, while the req.Host field
// specifies the Host header value to send in the HTTP request. If this is false, the incoming req.Host header will
// just be forwarded to the backend server.
UseLocationHost bool
// FlushInterval controls how often the standard HTTP proxy will flush content from the upstream.
FlushInterval time.Duration
// MaxBytesPerSec controls the maximum rate for an upstream connection. No rate is imposed if the value is zero.
MaxBytesPerSec int64
// Responder is passed errors that occur while setting up proxying.
Responder ErrorResponder
// Reject to forward redirect response
RejectForwardingRedirects bool
}
UpgradeAwareHandler is a handler for proxy requests that may require an upgrade
func NewUpgradeAwareHandler ¶
func NewUpgradeAwareHandler(location *url.URL, transport http.RoundTripper, wrapTransport, upgradeRequired bool, responder ErrorResponder) *UpgradeAwareHandler
NewUpgradeAwareHandler creates a new proxy handler with a default flush interval. Responder is required for returning errors to the caller.
func (*UpgradeAwareHandler) DialForUpgrade ¶
func (*UpgradeAwareHandler) ServeHTTP ¶
func (h *UpgradeAwareHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
ServeHTTP handles the proxy request
type UpgradeRequestRoundTripper ¶
type UpgradeRequestRoundTripper interface {
http.RoundTripper
// WrapRequest takes a valid HTTP request and returns a suitably altered version
// of request with any HTTP level values required to complete the request half of
// an upgrade on the server. It does not get a chance to see the response and
// should bypass any request side logic that expects to see the response.
WrapRequest(*http.Request) (*http.Request, error)
}
UpgradeRequestRoundTripper provides an additional method to decorate a request with any authentication or other protocol level information prior to performing an upgrade on the server. Any response will be handled by the intercepting proxy.
func NewUpgradeRequestRoundTripper ¶
func NewUpgradeRequestRoundTripper(connection, request http.RoundTripper) UpgradeRequestRoundTripper
NewUpgradeRequestRoundTripper takes two round trippers - one for the underlying TCP connection, and one that is able to write headers to an HTTP request. The request rt is used to set the request headers and that is written to the underlying connection rt.
Source Files