Documentation
¶
Index ¶
- func NewMetricsRegistry(config config.PrometheusConfig) *mr.Registry
- type Metrics
- func (metrics *Metrics) CaptureBackendExhaustedConns()
- func (metrics *Metrics) CaptureBackendInvalidID()
- func (metrics *Metrics) CaptureBackendInvalidTLSCert()
- func (metrics *Metrics) CaptureBackendTLSHandshakeFailed()
- func (metrics *Metrics) CaptureBadGateway()
- func (metrics *Metrics) CaptureBadRequest()
- func (metrics *Metrics) CaptureEmptyContentLengthHeader()
- func (metrics *Metrics) CaptureFoundFileDescriptors(files int)
- func (metrics *Metrics) CaptureGorouterTime(t float64)
- func (metrics *Metrics) CaptureHTTPLatency(d time.Duration, sourceID string)
- func (metrics *Metrics) CaptureLookupTime(t time.Duration)
- func (metrics *Metrics) CaptureNATSBufferedMessages(messages int)
- func (metrics *Metrics) CaptureNATSDroppedMessages(messages int)
- func (metrics *Metrics) CaptureRegistryMessage(msg metrics.ComponentTagged, action string)
- func (metrics *Metrics) CaptureRouteRegistrationLatency(t time.Duration)
- func (metrics *Metrics) CaptureRouteServiceResponse(res *http.Response)
- func (metrics *Metrics) CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)
- func (metrics *Metrics) CaptureRoutesPruned(routesPruned uint64)
- func (metrics *Metrics) CaptureRoutingRequest(b *route.Endpoint)
- func (metrics *Metrics) CaptureRoutingResponse(statusCode int)
- func (metrics *Metrics) CaptureRoutingResponseLatency(b *route.Endpoint, _ int, _ time.Time, d time.Duration)
- func (metrics *Metrics) CaptureTotalRoutes(totalRoutes int)
- func (metrics *Metrics) CaptureUnregistryMessage(msg metrics.ComponentTagged)
- func (metrics *Metrics) CaptureWebSocketFailure()
- func (metrics *Metrics) CaptureWebSocketUpdate()
- func (metrics *Metrics) UnmuzzleRouteRegistrationLatency()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMetricsRegistry ¶
func NewMetricsRegistry(config config.PrometheusConfig) *mr.Registry
Types ¶
type Metrics ¶
type Metrics struct {
RouteRegistration mr.CounterVec
RouteUnregistration mr.CounterVec
RoutesPruned mr.Counter
TotalRoutes mr.Gauge
TimeSinceLastRegistryUpdate mr.Gauge
RouteLookupTime mr.Histogram
GorouterTime mr.Histogram
RouteRegistrationLatency mr.Histogram
RoutingRequest mr.CounterVec
BadRequest mr.Counter
BadGateway mr.Counter
EmptyContentLengthHeader mr.Counter
BackendInvalidID mr.Counter
BackendInvalidTLSCert mr.Counter
BackendTLSHandshakeFailed mr.Counter
BackendExhaustedConns mr.Counter
WebsocketUpgrades mr.Counter
WebsocketFailures mr.Counter
Responses mr.CounterVec
RouteServicesResponses mr.CounterVec
RoutingResponseLatency mr.HistogramVec
FoundFileDescriptors mr.Gauge
NATSBufferedMessages mr.Gauge
NATSDroppedMessages mr.Gauge
HTTPLatency mr.HistogramVec
// contains filtered or unexported fields
}
Metrics represents a prometheus metrics endpoint.
func NewMetrics ¶
func (*Metrics) CaptureBackendExhaustedConns ¶
func (metrics *Metrics) CaptureBackendExhaustedConns()
func (*Metrics) CaptureBackendInvalidID ¶
func (metrics *Metrics) CaptureBackendInvalidID()
func (*Metrics) CaptureBackendInvalidTLSCert ¶
func (metrics *Metrics) CaptureBackendInvalidTLSCert()
func (*Metrics) CaptureBackendTLSHandshakeFailed ¶
func (metrics *Metrics) CaptureBackendTLSHandshakeFailed()
func (*Metrics) CaptureBadGateway ¶
func (metrics *Metrics) CaptureBadGateway()
func (*Metrics) CaptureBadRequest ¶
func (metrics *Metrics) CaptureBadRequest()
func (*Metrics) CaptureEmptyContentLengthHeader ¶
func (metrics *Metrics) CaptureEmptyContentLengthHeader()
func (*Metrics) CaptureFoundFileDescriptors ¶
func (*Metrics) CaptureGorouterTime ¶
func (*Metrics) CaptureHTTPLatency ¶
func (*Metrics) CaptureLookupTime ¶
func (*Metrics) CaptureNATSBufferedMessages ¶
func (*Metrics) CaptureNATSDroppedMessages ¶
func (*Metrics) CaptureRegistryMessage ¶
func (metrics *Metrics) CaptureRegistryMessage(msg metrics.ComponentTagged, action string)
func (*Metrics) CaptureRouteRegistrationLatency ¶
func (*Metrics) CaptureRouteServiceResponse ¶
func (*Metrics) CaptureRouteStats ¶
func (*Metrics) CaptureRoutesPruned ¶
func (*Metrics) CaptureRoutingRequest ¶
CaptureRoutingRequest used to capture backend round trips
func (*Metrics) CaptureRoutingResponse ¶
func (*Metrics) CaptureRoutingResponseLatency ¶
func (metrics *Metrics) CaptureRoutingResponseLatency(b *route.Endpoint, _ int, _ time.Time, d time.Duration)
CaptureRoutingResponseLatency has extra arguments to match varz reporter
func (*Metrics) CaptureTotalRoutes ¶
func (*Metrics) CaptureUnregistryMessage ¶
func (metrics *Metrics) CaptureUnregistryMessage(msg metrics.ComponentTagged)
func (*Metrics) CaptureWebSocketFailure ¶
func (metrics *Metrics) CaptureWebSocketFailure()
func (*Metrics) CaptureWebSocketUpdate ¶
func (metrics *Metrics) CaptureWebSocketUpdate()
func (*Metrics) UnmuzzleRouteRegistrationLatency ¶
func (metrics *Metrics) UnmuzzleRouteRegistrationLatency()
UnmuzzleRouteRegistrationLatency should set a flag which suppresses metric data. That makes sense for Envelope V1 where we send it to collector any time we got new value but is unnecessary for Prometheus where data is buffered and sent to collector on constant frequency base. We still need this method though to fulfil the interface.
Source Files
Click to show internal directories.
Click to hide internal directories.