metrics

Documentation

Index

• type ComponentTagged
• type CompositeReporter
  • func (c *CompositeReporter) CaptureBadGateway()
  • func (c *CompositeReporter) CaptureBadRequest()
  • func (c *CompositeReporter) CaptureEmptyContentLengthHeader()
  • func (c *CompositeReporter) CaptureRoutingRequest(b *route.Endpoint)
  • func (c *CompositeReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
• type MetricsReporter
  • func (m *MetricsReporter) CaptureBackendExhaustedConns()
  • func (m *MetricsReporter) CaptureBackendInvalidID()
  • func (m *MetricsReporter) CaptureBackendInvalidTLSCert()
  • func (m *MetricsReporter) CaptureBackendTLSHandshakeFailed()
  • func (m *MetricsReporter) CaptureBadGateway()
  • func (m *MetricsReporter) CaptureBadRequest()
  • func (m *MetricsReporter) CaptureEmptyContentLengthHeader()
  • func (m *MetricsReporter) CaptureLookupTime(t time.Duration)
  • func (m *MetricsReporter) CaptureRegistryMessage(msg ComponentTagged)
  • func (m *MetricsReporter) CaptureRouteRegistrationLatency(t time.Duration)
  • func (m *MetricsReporter) CaptureRouteServiceResponse(res *http.Response)
  • func (m *MetricsReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)
  • func (m *MetricsReporter) CaptureRoutesPruned(routesPruned uint64)
  • func (m *MetricsReporter) CaptureRoutingRequest(b *route.Endpoint)
  • func (m *MetricsReporter) CaptureRoutingResponse(statusCode int)
  • func (m *MetricsReporter) CaptureRoutingResponseLatency(b *route.Endpoint, _ int, _ time.Time, d time.Duration)
  • func (m *MetricsReporter) CaptureUnregistryMessage(msg ComponentTagged)
  • func (m *MetricsReporter) CaptureWebSocketFailure()
  • func (m *MetricsReporter) CaptureWebSocketUpdate()
  • func (m *MetricsReporter) UnmuzzleRouteRegistrationLatency()
• type ProxyReporter
• type RouteRegistryReporter
• type VarzReporter

Types

type ComponentTagged

type ComponentTagged interface {
	Component() string
}

type CompositeReporter

type CompositeReporter struct {
	VarzReporter
	ProxyReporter
}

func (*CompositeReporter) CaptureBadGateway

func (c *CompositeReporter) CaptureBadGateway()

func (*CompositeReporter) CaptureBadRequest

func (c *CompositeReporter) CaptureBadRequest()

func (*CompositeReporter) CaptureEmptyContentLengthHeader

func (c *CompositeReporter) CaptureEmptyContentLengthHeader()

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 MetricsReporter

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

func (*MetricsReporter) CaptureBackendExhaustedConns

func (m *MetricsReporter) CaptureBackendExhaustedConns()

func (*MetricsReporter) CaptureBackendInvalidID

func (m *MetricsReporter) CaptureBackendInvalidID()

func (*MetricsReporter) CaptureBackendInvalidTLSCert

func (m *MetricsReporter) CaptureBackendInvalidTLSCert()

func (*MetricsReporter) CaptureBackendTLSHandshakeFailed

func (m *MetricsReporter) CaptureBackendTLSHandshakeFailed()

func (*MetricsReporter) CaptureBadGateway

func (m *MetricsReporter) CaptureBadGateway()

func (*MetricsReporter) CaptureBadRequest

func (m *MetricsReporter) CaptureBadRequest()

func (*MetricsReporter) CaptureEmptyContentLengthHeader

func (m *MetricsReporter) CaptureEmptyContentLengthHeader()

func (*MetricsReporter) CaptureLookupTime

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

func (*MetricsReporter) CaptureRegistryMessage

func (m *MetricsReporter) CaptureRegistryMessage(msg ComponentTagged)

func (*MetricsReporter) CaptureRouteRegistrationLatency

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

func (*MetricsReporter) CaptureRouteServiceResponse

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

func (*MetricsReporter) CaptureRouteStats

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

func (*MetricsReporter) CaptureRoutesPruned

func (m *MetricsReporter) CaptureRoutesPruned(routesPruned uint64)

func (*MetricsReporter) CaptureRoutingRequest

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

func (*MetricsReporter) CaptureRoutingResponse

func (m *MetricsReporter) CaptureRoutingResponse(statusCode int)

func (*MetricsReporter) CaptureRoutingResponseLatency

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

func (*MetricsReporter) CaptureUnregistryMessage

func (m *MetricsReporter) CaptureUnregistryMessage(msg ComponentTagged)

func (*MetricsReporter) CaptureWebSocketFailure

func (m *MetricsReporter) CaptureWebSocketFailure()

func (*MetricsReporter) CaptureWebSocketUpdate

func (m *MetricsReporter) CaptureWebSocketUpdate()

func (*MetricsReporter) UnmuzzleRouteRegistrationLatency

func (m *MetricsReporter) UnmuzzleRouteRegistrationLatency()

type ProxyReporter

type ProxyReporter 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)
	CaptureRouteServiceResponse(res *http.Response)
	CaptureWebSocketUpdate()
	CaptureWebSocketFailure()
}

type RouteRegistryReporter

type RouteRegistryReporter interface {
	CaptureRouteStats(totalRoutes int, msSinceLastUpdate int64)
	CaptureRoutesPruned(prunedRoutes uint64)
	CaptureLookupTime(t time.Duration)
	CaptureRegistryMessage(msg ComponentTagged)
	CaptureRouteRegistrationLatency(t time.Duration)
	UnmuzzleRouteRegistrationLatency()
	CaptureUnregistryMessage(msg ComponentTagged)
}

type VarzReporter

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