proxy

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

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

type HTTPProxy struct {

	// stats contains all of the stats bits
	Stats HttpStatsHandler

	// 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

	// 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

	// 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

	// Config is the proxy configuration as provided during startup.
	Config config.Proxy
}

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 struct {
	Proxy *tcpproxy.Proxy
	// contains filtered or unexported fields
}

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