http

Documentation

Index

• Variables
• func NewJSONMessage(msgMap map[string]interface{}) ([]byte, error)
• func RecordMetrics(start time.Time, status int, writer http.ResponseWriter, request *http.Request)
• func WriteResponse(w http.ResponseWriter, content []byte, status int, logger *zap.Logger)
• type Router
  • func NewRouter(grpcAddr string, logger *zap.Logger) (*Router, error)
  • func (r *Router) Close() error
• type Server
  • func NewServer(httpAddr string, router *Router, logger *zap.Logger, ...) (*Server, error)
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Variables

var (
	DurationSeconds = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "handling_seconds",
			Help:      "The invocation duration in seconds.",
		},
		[]string{
			"request_uri",
		},
	)

	RequestsTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "handled_total",
			Help:      "The number of requests.",
		},
		[]string{
			"request_uri",
			"http_method",
			"http_status",
		},
	)

	RequestsBytesTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "requests_received_bytes",
			Help:      "A summary of the invocation requests bytes.",
		},
		[]string{
			"request_uri",
			"http_method",
		},
	)

	ResponsesBytesTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: namespace,
			Subsystem: subsystem,
			Name:      "responses_sent_bytes",
			Help:      "A summary of the invocation responses bytes.",
		},
		[]string{
			"request_uri",
			"http_method",
		},
	)
)

Functions

func NewJSONMessage

func NewJSONMessage(msgMap map[string]interface{}) ([]byte, error)

func RecordMetrics

func RecordMetrics(start time.Time, status int, writer http.ResponseWriter, request *http.Request)

func WriteResponse

func WriteResponse(w http.ResponseWriter, content []byte, status int, logger *zap.Logger)

Types

type Router

type Router struct {
	mux.Router

	GRPCClient *grpc.Client
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(grpcAddr string, logger *zap.Logger) (*Router, error)

func (*Router) Close

func (r *Router) Close() error

type Server

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

func NewServer

func NewServer(httpAddr string, router *Router, logger *zap.Logger, httpLogger accesslog.Logger) (*Server, error)

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error