reverseproxy

Documentation

Index

• type Metrics
  • func NewMetrics(subsystem string) *Metrics
  • func (m *Metrics) Handler(endpoint string) gin.HandlerFunc
  • func (m *Metrics) Register(registry *prometheus.Registry)
• type ReverseProxy
  • func NewReverseProxy(conf config.ListenerConfig, logger log.Logger) *ReverseProxy
  • func (p *ReverseProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Server
  • func NewServer(conf config.ListenerConfig, metrics *Metrics, logger log.Logger) *Server
  • func (s *Server) Serve(ln net.Listener) error
  • func (s *Server) Shutdown(ctx context.Context) error

Types

type Metrics

type Metrics struct {
	RequestsInFlight *prometheus.GaugeVec
	RequestsTotal    *prometheus.CounterVec
	RequestLatency   *prometheus.HistogramVec
	RequestSize      *prometheus.HistogramVec
	ResponseSize     *prometheus.HistogramVec
}

func NewMetrics

func NewMetrics(subsystem string) *Metrics

func (*Metrics) Handler

func (m *Metrics) Handler(endpoint string) gin.HandlerFunc

func (*Metrics) Register

func (m *Metrics) Register(registry *prometheus.Registry)

type ReverseProxy

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

func NewReverseProxy

func NewReverseProxy(conf config.ListenerConfig, 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(
	conf config.ListenerConfig,
	metrics *Metrics,
	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