proxy

Documentation

Index

• func EndpointIDFromRequest(r *http.Request) string
• type HTTPProxy
  • func NewHTTPProxy(upstreams upstream.Manager, timeout time.Duration, logger log.Logger) *HTTPProxy
  • func (p *HTTPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request, endpointID string)
  • func (p *HTTPProxy) ServeHTTPWithUpstream(w http.ResponseWriter, r *http.Request, endpointID string, ...)
• type Server
  • func NewServer(upstreams upstream.Manager, proxyConfig config.ProxyConfig, ...) *Server
  • func (s *Server) Serve(ln net.Listener) error
  • func (s *Server) Shutdown(ctx context.Context) error
• type TCPProxy
  • func NewTCPProxy(upstreams upstream.Manager, httpProxy *HTTPProxy, logger log.Logger) *TCPProxy
  • func (p *TCPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request, endpointID string)

Functions

func EndpointIDFromRequest

func EndpointIDFromRequest(r *http.Request) string

EndpointIDFromRequest returns the endpoint ID from the HTTP request, or an empty string if no endpoint ID is specified.

This will check both the 'x-piko-endpoint' header and 'Host' header, where x-piko-endpoint takes precedence.

Types

type HTTPProxy

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

HTTPProxy proxies HTTP traffic to upsteam listeners.

func NewHTTPProxy

func NewHTTPProxy(
	upstreams upstream.Manager,
	timeout time.Duration,
	logger log.Logger,
) *HTTPProxy

func (*HTTPProxy) ServeHTTP

func (p *HTTPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request, endpointID string)

func (*HTTPProxy) ServeHTTPWithUpstream

func (p *HTTPProxy) ServeHTTPWithUpstream(
	w http.ResponseWriter,
	r *http.Request,
	endpointID string,
	upstream upstream.Upstream,
)

type Server

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

func NewServer

func NewServer(
	upstreams upstream.Manager,
	proxyConfig config.ProxyConfig,
	registry *prometheus.Registry,
	verifier *auth.MultiTenantVerifier,
	tlsConfig *tls.Config,
	logger log.Logger,
) *Server

func (*Server) Serve

func (s *Server) Serve(ln net.Listener) error

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

type TCPProxy

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

TCPProxy proxies TCP traffic to upstream listeners.

Incoming TCP traffic is sent over WebSockets by a Piko client, then forwarded to an upstream via a multiplexed stream.

func NewTCPProxy

func NewTCPProxy(
	upstreams upstream.Manager,
	httpProxy *HTTPProxy,
	logger log.Logger,
) *TCPProxy

func (*TCPProxy) ServeHTTP

func (p *TCPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request, endpointID string)