metrics

package
v0.0.0-...-a602bb6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2025 License: Apache-2.0, BSD-2-Clause-Views, BSD-3-Clause, + 1 more Imports: 9 Imported by: 38

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ComponentTagged 

type ComponentTagged interface {
	Component() string
}

type CompositeReporter 

type CompositeReporter struct {
	VarzReporter
	MetricReporter
}

func (*CompositeReporter) CaptureBadGateway 

func (c *CompositeReporter) CaptureBadGateway()

func (*CompositeReporter) CaptureBadRequest 

func (c *CompositeReporter) CaptureBadRequest()

func (*CompositeReporter) CaptureEmptyContentLengthHeader 

func (c *CompositeReporter) CaptureEmptyContentLengthHeader()

func (*CompositeReporter) CaptureHTTPLatency 

func (c *CompositeReporter) CaptureHTTPLatency(d time.Duration, sourceID string)

func (*CompositeReporter) CaptureRoutingRequest 

func (c *CompositeReporter) CaptureRoutingRequest(b *route.Endpoint)

func (*CompositeReporter) CaptureRoutingResponseLatency 

func (c *CompositeReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)

type MetricReporter 

type MetricReporter interface {
	CaptureBackendExhaustedConns()
	CaptureBackendInvalidID()
	CaptureBackendInvalidTLSCert()
	CaptureBackendTLSHandshakeFailed()
	CaptureBadRequest()
	CaptureBadGateway()
	CaptureEmptyContentLengthHeader()
	CaptureRoutingRequest(b *route.Endpoint)
	CaptureRoutingResponse(statusCode int)
	CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
	CaptureGorouterTime(gorouterTime float64)
	CaptureRouteServiceResponse(res *http.Response)
	CaptureWebSocketUpdate()
	CaptureWebSocketFailure()
	CaptureHTTPLatency(d time.Duration, sourceID string)
	CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)
	CaptureRoutesPruned(prunedRoutes uint64)
	CaptureLookupTime(t time.Duration)
	CaptureRegistryMessage(msg ComponentTagged, action string)
	CaptureRouteRegistrationLatency(t time.Duration)
	CaptureUnregistryMessage(msg ComponentTagged)
	CaptureFoundFileDescriptors(files int)
	CaptureNATSBufferedMessages(messages int)
	CaptureNATSDroppedMessages(messages int)
	UnmuzzleRouteRegistrationLatency()
}

type Metrics 

type Metrics struct {
	Sender                     metrics.MetricSender
	Batcher                    metrics.MetricBatcher
	PerRequestMetricsReporting bool
	Logger                     *slog.Logger
	// contains filtered or unexported fields
}

func (*Metrics) CaptureBackendExhaustedConns 

func (m *Metrics) CaptureBackendExhaustedConns()

func (*Metrics) CaptureBackendInvalidID 

func (m *Metrics) CaptureBackendInvalidID()

func (*Metrics) CaptureBackendInvalidTLSCert 

func (m *Metrics) CaptureBackendInvalidTLSCert()

func (*Metrics) CaptureBackendTLSHandshakeFailed 

func (m *Metrics) CaptureBackendTLSHandshakeFailed()

func (*Metrics) CaptureBadGateway 

func (m *Metrics) CaptureBadGateway()

func (*Metrics) CaptureBadRequest 

func (m *Metrics) CaptureBadRequest()

func (*Metrics) CaptureEmptyContentLengthHeader 

func (m *Metrics) CaptureEmptyContentLengthHeader()

func (*Metrics) CaptureFoundFileDescriptors 

func (m *Metrics) CaptureFoundFileDescriptors(files int)

func (*Metrics) CaptureGorouterTime 

func (m *Metrics) CaptureGorouterTime(gorouterTime float64)

func (*Metrics) CaptureHTTPLatency 

func (m *Metrics) CaptureHTTPLatency(_ time.Duration, _ string)

CaptureHTTPLatency observes histogram of HTTP latency metric Empty implementation here is to fulfil interface

func (*Metrics) CaptureLookupTime 

func (m *Metrics) CaptureLookupTime(t time.Duration)

func (*Metrics) CaptureNATSBufferedMessages 

func (m *Metrics) CaptureNATSBufferedMessages(messages int)

func (*Metrics) CaptureNATSDroppedMessages 

func (m *Metrics) CaptureNATSDroppedMessages(messages int)

func (*Metrics) CaptureRegistryMessage 

func (m *Metrics) CaptureRegistryMessage(msg ComponentTagged, _ string)

func (*Metrics) CaptureRouteRegistrationLatency 

func (m *Metrics) CaptureRouteRegistrationLatency(t time.Duration)

func (*Metrics) CaptureRouteServiceResponse 

func (m *Metrics) CaptureRouteServiceResponse(res *http.Response)

func (*Metrics) CaptureRouteStats 

func (m *Metrics) CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)

func (*Metrics) CaptureRoutesPruned 

func (m *Metrics) CaptureRoutesPruned(routesPruned uint64)

func (*Metrics) CaptureRoutingRequest 

func (m *Metrics) CaptureRoutingRequest(b *route.Endpoint)

func (*Metrics) CaptureRoutingResponse 

func (m *Metrics) CaptureRoutingResponse(statusCode int)

func (*Metrics) CaptureRoutingResponseLatency 

func (m *Metrics) CaptureRoutingResponseLatency(b *route.Endpoint, _ int, _ time.Time, d time.Duration)

func (*Metrics) CaptureUnregistryMessage 

func (m *Metrics) CaptureUnregistryMessage(msg ComponentTagged)

func (*Metrics) CaptureWebSocketFailure 

func (m *Metrics) CaptureWebSocketFailure()

func (*Metrics) CaptureWebSocketUpdate 

func (m *Metrics) CaptureWebSocketUpdate()

func (*Metrics) UnmuzzleRouteRegistrationLatency 

func (m *Metrics) UnmuzzleRouteRegistrationLatency()

type MultiMetricReporter 

type MultiMetricReporter []MetricReporter

func NewMultiMetricReporter 

func NewMultiMetricReporter(reporters ...MetricReporter) MultiMetricReporter

func (MultiMetricReporter) CaptureBackendExhaustedConns 

func (m MultiMetricReporter) CaptureBackendExhaustedConns()

func (MultiMetricReporter) CaptureBackendInvalidID 

func (m MultiMetricReporter) CaptureBackendInvalidID()

func (MultiMetricReporter) CaptureBackendInvalidTLSCert 

func (m MultiMetricReporter) CaptureBackendInvalidTLSCert()

func (MultiMetricReporter) CaptureBackendTLSHandshakeFailed 

func (m MultiMetricReporter) CaptureBackendTLSHandshakeFailed()

func (MultiMetricReporter) CaptureBadGateway 

func (m MultiMetricReporter) CaptureBadGateway()

func (MultiMetricReporter) CaptureBadRequest 

func (m MultiMetricReporter) CaptureBadRequest()

func (MultiMetricReporter) CaptureEmptyContentLengthHeader 

func (m MultiMetricReporter) CaptureEmptyContentLengthHeader()

func (MultiMetricReporter) CaptureFoundFileDescriptors 

func (m MultiMetricReporter) CaptureFoundFileDescriptors(files int)

func (MultiMetricReporter) CaptureGorouterTime 

func (m MultiMetricReporter) CaptureGorouterTime(gorouterTime float64)

func (MultiMetricReporter) CaptureHTTPLatency 

func (m MultiMetricReporter) CaptureHTTPLatency(d time.Duration, sourceID string)

func (MultiMetricReporter) CaptureLookupTime 

func (m MultiMetricReporter) CaptureLookupTime(t time.Duration)

func (MultiMetricReporter) CaptureNATSBufferedMessages 

func (m MultiMetricReporter) CaptureNATSBufferedMessages(messages int)

func (MultiMetricReporter) CaptureNATSDroppedMessages 

func (m MultiMetricReporter) CaptureNATSDroppedMessages(messages int)

func (MultiMetricReporter) CaptureRegistryMessage 

func (m MultiMetricReporter) CaptureRegistryMessage(msg ComponentTagged, action string)

func (MultiMetricReporter) CaptureRouteRegistrationLatency 

func (m MultiMetricReporter) CaptureRouteRegistrationLatency(t time.Duration)

func (MultiMetricReporter) CaptureRouteServiceResponse 

func (m MultiMetricReporter) CaptureRouteServiceResponse(res *http.Response)

func (MultiMetricReporter) CaptureRouteStats 

func (m MultiMetricReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)

func (MultiMetricReporter) CaptureRoutesPruned 

func (m MultiMetricReporter) CaptureRoutesPruned(routesPruned uint64)

func (MultiMetricReporter) CaptureRoutingRequest 

func (m MultiMetricReporter) CaptureRoutingRequest(b *route.Endpoint)

func (MultiMetricReporter) CaptureRoutingResponse 

func (m MultiMetricReporter) CaptureRoutingResponse(statusCode int)

func (MultiMetricReporter) CaptureRoutingResponseLatency 

func (m MultiMetricReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)

func (MultiMetricReporter) CaptureUnregistryMessage 

func (m MultiMetricReporter) CaptureUnregistryMessage(msg ComponentTagged)

func (MultiMetricReporter) CaptureWebSocketFailure 

func (m MultiMetricReporter) CaptureWebSocketFailure()

func (MultiMetricReporter) CaptureWebSocketUpdate 

func (m MultiMetricReporter) CaptureWebSocketUpdate()

func (MultiMetricReporter) UnmuzzleRouteRegistrationLatency 

func (m MultiMetricReporter) UnmuzzleRouteRegistrationLatency()

type VarzReporter deprecated 

type VarzReporter interface {
	CaptureBadRequest()
	CaptureBadGateway()
	CaptureRoutingRequest(b *route.Endpoint)
	CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
}

Deprecated: this interface is marked for removal. It should be removed upon removal of Varz

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.