proxy

Documentation

Index

• func EndpointIDFromRequest(r *http.Request) string
• type ReverseProxy
  • func NewReverseProxy(upstreams upstream.Manager, timeout time.Duration, logger log.Logger) *ReverseProxy
  • func (p *ReverseProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• 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

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 ReverseProxy

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

func NewReverseProxy

func NewReverseProxy(
	upstreams upstream.Manager,
	timeout time.Duration,
	logger log.Logger,
) *ReverseProxy

func (*ReverseProxy) ServeHTTP

func (p *ReverseProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Server

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

func NewServer

func NewServer(
	upstreams upstream.Manager,
	proxyConfig config.ProxyConfig,
	registry *prometheus.Registry,
	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