metrics

Documentation

Index

• Constants
• Variables
• type LatencyAdapter
  • func (l *LatencyAdapter) Observe(_ context.Context, verb string, u url.URL, latency time.Duration)
• type RegistererGatherer
• type Server
  • func NewServer(port int) (*Server, error)
  • func (s *Server) Shutdown() error
  • func (s *Server) Start() (err error)

Constants

const (
	RestClientSubsystem = "rest_client"
	LatencyKey          = "request_latency_seconds"
	ResultKey           = "requests_total"
)

Metrics subsystem and all of the keys used by the rest client.

Variables

var (

	// To prevent cardinality explosion, only the verb is added as a label to latency metrics
	RequestLatency = prometheus.NewHistogramVec(prometheus.HistogramOpts{
		Subsystem: RestClientSubsystem,
		Name:      LatencyKey,
		Help:      "Request latency in seconds. Broken down by verb.",
		Buckets:   prometheus.ExponentialBuckets(0.001, 2, 10),
	}, []string{"verb"})
)

Types

type LatencyAdapter

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

LatencyAdapter implements LatencyMetric.

func (*LatencyAdapter) Observe

func (l *LatencyAdapter) Observe(_ context.Context, verb string, u url.URL, latency time.Duration)

Observe increments the request latency metric for the given verb/URL.

type RegistererGatherer

type RegistererGatherer interface {
	prometheus.Registerer
	prometheus.Gatherer
}

RegistererGatherer combines both parts of the API of a Prometheus registry, both the Registerer and the Gatherer interfaces.

var Registry RegistererGatherer = prometheus.NewRegistry()

Registry is a prometheus registry for storing metrics.

type Server

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

func NewServer

func NewServer(port int) (*Server, error)

func (*Server) Shutdown

func (s *Server) Shutdown() error

func (*Server) Start

func (s *Server) Start() (err error)