proxy

Documentation

Index

• Constants
• func Close()
• func CloseProxy(address string) error
• func GetGRPCDirector(tlscfg *tls.Config, cfg *config.Config) ...
• func ListenAndServeGRPC(l config.Listen, opts []grpc.ServerOption, cfg *tls.Config) error
• func ListenAndServeHTTP(l config.Listen, h http.Handler, cfg *tls.Config) error
• func ListenAndServeHTTPSTCPSNI(l config.Listen, h http.Handler, p tcp.Handler, cfg *tls.Config, ...) error
• func ListenAndServePrometheus(l config.Listen, pcfg config.Prometheus, cfg *tls.Config) error
• func ListenAndServeTCP(l config.Listen, h tcp.Handler, cfg *tls.Config) error
• func ListenTCP(l config.Listen, cfg *tls.Config) (net.Listener, error)
• func Shutdown(timeout time.Duration)
• type GrpcProxyInterceptor
  • func (g GrpcProxyInterceptor) Stream(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type GrpcStatsHandler
  • func (h *GrpcStatsHandler) HandleConn(ctx context.Context, conn stats.ConnStats)
  • func (h *GrpcStatsHandler) HandleRPC(ctx context.Context, rpc stats.RPCStats)
  • func (h *GrpcStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context
  • func (h *GrpcStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context
• type HTTPProxy
  • func (p *HTTPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type HttpStatsHandler
• type InetAfTCPProxyServer
  • func (tps *InetAfTCPProxyServer) Close() error
  • func (tps *InetAfTCPProxyServer) Serve(_ net.Listener) error
  • func (tps *InetAfTCPProxyServer) ServeLater(l net.Listener, s Server)
  • func (tps *InetAfTCPProxyServer) Shutdown(ctx context.Context) error
• type Server

Constants

const StatusClientClosedRequest = 499

StatusClientClosedRequest non-standard HTTP status code for client disconnection

Functions

func Close

func Close()

func CloseProxy

func CloseProxy(address string) error

func GetGRPCDirector

func GetGRPCDirector(tlscfg *tls.Config, cfg *config.Config) func(ctx context.Context, fullMethodName string) (context.Context, *grpc.ClientConn, error)

func ListenAndServeGRPC

func ListenAndServeGRPC(l config.Listen, opts []grpc.ServerOption, cfg *tls.Config) error

func ListenAndServeHTTP

func ListenAndServeHTTP(l config.Listen, h http.Handler, cfg *tls.Config) error

func ListenAndServeHTTPSTCPSNI

func ListenAndServeHTTPSTCPSNI(l config.Listen, h http.Handler, p tcp.Handler, cfg *tls.Config, m tcpproxy.Matcher) error

func ListenAndServePrometheus

func ListenAndServePrometheus(l config.Listen, pcfg config.Prometheus, cfg *tls.Config) error

func ListenAndServeTCP

func ListenAndServeTCP(l config.Listen, h tcp.Handler, cfg *tls.Config) error

func ListenTCP

func ListenTCP(l config.Listen, cfg *tls.Config) (net.Listener, error)

func Shutdown

func Shutdown(timeout time.Duration)

Types

type GrpcProxyInterceptor

type GrpcProxyInterceptor struct {
	Config       *config.Config
	StatsHandler *GrpcStatsHandler
	GlobCache    *route.GlobCache
}

func (GrpcProxyInterceptor) Stream

func (g GrpcProxyInterceptor) Stream(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

type GrpcStatsHandler

type GrpcStatsHandler struct {
	Connect gkm.Counter
	Request gkm.Histogram
	NoRoute gkm.Counter
	Status  gkm.Histogram
}

func (*GrpcStatsHandler) HandleConn

func (h *GrpcStatsHandler) HandleConn(ctx context.Context, conn stats.ConnStats)

HandleConn processes the Conn stats.

func (*GrpcStatsHandler) HandleRPC

func (h *GrpcStatsHandler) HandleRPC(ctx context.Context, rpc stats.RPCStats)

func (*GrpcStatsHandler) TagConn

func (h *GrpcStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context

func (*GrpcStatsHandler) TagRPC

func (h *GrpcStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

type HTTPProxy

type HTTPProxy struct {
	// Config is the proxy configuration as provided during startup.
	Config config.Proxy

	// Time returns the current time as the number of seconds since the epoch.
	// If Time is nil, time.Now is used.
	Time func() time.Time

	// Transport is the http connection pool configured with timeouts.
	// The proxy will panic if this value is nil.
	Transport http.RoundTripper

	// InsecureTransport is the http connection pool configured with
	// InsecureSkipVerify set. This is used for https proxies with
	// self-signed certs.
	InsecureTransport http.RoundTripper

	// Lookup returns a target host for the given request.
	// The proxy will panic if this value is nil.
	Lookup func(*http.Request) *route.Target

	// Logger is the access logger for the requests.
	Logger logger.Logger

	// TracerCfg is the Open Tracing configuration as provided during startup
	TracerCfg config.Tracing

	// UUID returns a unique id in uuid format.
	// If UUID is nil, uuid.NewUUID() is used.
	UUID func() string

	// Auth schemes registered with the server
	AuthSchemes map[string]auth.AuthScheme

	// stats contains all of the stats bits
	Stats HttpStatsHandler
}

HTTPProxy is a dynamic reverse proxy for HTTP and HTTPS protocols.

func (*HTTPProxy) ServeHTTP

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

type HttpStatsHandler

type HttpStatsHandler struct {
	// Requests is a histogram metric which is updated for every request.
	Requests gkm.Histogram

	// Noroute is a counter metric which is updated for every request
	// where Lookup() returns nil.
	Noroute gkm.Counter

	// WSConn counts the number of open web socket connections.
	WSConn gkm.Gauge

	// StatusTimer is a histogram for given status codes
	StatusTimer gkm.Histogram

	// RedirectCounter - counts redirects
	RedirectCounter gkm.Counter
}

type InetAfTCPProxyServer

type InetAfTCPProxyServer struct {
	Proxy *tcpproxy.Proxy
	// contains filtered or unexported fields
}

func (*InetAfTCPProxyServer) Close

func (tps *InetAfTCPProxyServer) Close() error

Close - implements Server - is this even called?

func (*InetAfTCPProxyServer) Serve

func (tps *InetAfTCPProxyServer) Serve(_ net.Listener) error

Serve - implements server. The listener is ignored, but it calls serve on the children

func (*InetAfTCPProxyServer) ServeLater

func (tps *InetAfTCPProxyServer) ServeLater(l net.Listener, s Server)

ServeLater - l is really only for listeners that are tcpproxy.TargetListener or a derivative. Don't call after Serve() is called.

func (*InetAfTCPProxyServer) Shutdown

func (tps *InetAfTCPProxyServer) Shutdown(ctx context.Context) error

type Server

type Server interface {
	Close() error
	Serve(l net.Listener) error
	Shutdown(ctx context.Context) error
}