metrics

Documentation

Index

• func InterceptSdk(sdkId string, metricsHandler Handler, transport http.RoundTripper) http.RoundTripper
• func Measure(metricsHandler Handler, next http.HandlerFunc) http.HandlerFunc
• type Handler
  • func NewHandler() Handler
• type Server
  • func NewServer(handler http.Handler, conf *config.MetricsConfig, log log.Logger, ...) *Server
  • func (h *Server) Listen()
  • func (h *Server) Shutdown()

Functions

func InterceptSdk

func InterceptSdk(sdkId string, metricsHandler Handler, transport http.RoundTripper) http.RoundTripper

func Measure

func Measure(metricsHandler Handler, next http.HandlerFunc) http.HandlerFunc

Types

type Handler

type Handler interface {
	IncrementConnection(sdkId string, streamType string, flag string)
	DecrementConnection(sdkId string, streamType string, flag string)

	HttpHandler() http.Handler
}

func NewHandler

func NewHandler() Handler

type Server

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

func NewServer

func NewServer(handler http.Handler, conf *config.MetricsConfig, log log.Logger, errorChan chan error) *Server

func (*Server) Listen

func (h *Server) Listen()

func (*Server) Shutdown

func (h *Server) Shutdown()