metrics

Documentation

Index

• type CombinedReporter
  • func NewCompositeReporter(varzReporter VarzReporter, proxyReporter ProxyReporter) CombinedReporter
• type ComponentTagged
• type CompositeReporter
  • func (c *CompositeReporter) CaptureBadGateway()
  • func (c *CompositeReporter) CaptureBadRequest()
  • func (c *CompositeReporter) CaptureRouteServiceResponse(res *http.Response)
  • func (c *CompositeReporter) CaptureRoutingRequest(b *route.Endpoint)
  • func (c *CompositeReporter) CaptureRoutingResponse(statusCode int)
  • func (c *CompositeReporter) CaptureRoutingResponseLatency(b *route.Endpoint, statusCode int, t time.Time, d time.Duration)
  • func (c *CompositeReporter) CaptureWebSocketFailure()
  • func (c *CompositeReporter) CaptureWebSocketUpdate()
• type MetricsReporter
  • func NewMetricsReporter(sender metrics.MetricSender, batcher metrics.MetricBatcher) *MetricsReporter
  • func (m *MetricsReporter) CaptureBadGateway()
  • func (m *MetricsReporter) CaptureBadRequest()
  • func (m *MetricsReporter) CaptureLookupTime(t time.Duration)
  • func (m *MetricsReporter) CaptureRegistryMessage(msg ComponentTagged)
  • func (m *MetricsReporter) CaptureRouteServiceResponse(res *http.Response)
  • func (m *MetricsReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate uint64)
  • func (m *MetricsReporter) CaptureRoutingRequest(b *route.Endpoint)
  • func (m *MetricsReporter) CaptureRoutingResponse(statusCode int)
  • func (m *MetricsReporter) CaptureRoutingResponseLatency(b *route.Endpoint, d time.Duration)
  • func (m *MetricsReporter) CaptureUnregistryMessage(msg ComponentTagged)
  • func (m *MetricsReporter) CaptureWebSocketFailure()
  • func (m *MetricsReporter) CaptureWebSocketUpdate()
• type ProxyReporter
• type RouteRegistryReporter
• type VarzReporter

Types

type CombinedReporter

type CombinedReporter interface {
	CaptureBadRequest()
	CaptureBadGateway()
	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()
}

func NewCompositeReporter

func NewCompositeReporter(varzReporter VarzReporter, proxyReporter ProxyReporter) CombinedReporter

type ComponentTagged

type ComponentTagged interface {
	Component() string
}

type CompositeReporter

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

func (*CompositeReporter) CaptureBadGateway

func (c *CompositeReporter) CaptureBadGateway()

func (*CompositeReporter) CaptureBadRequest

func (c *CompositeReporter) CaptureBadRequest()

func (*CompositeReporter) CaptureRouteServiceResponse

func (c *CompositeReporter) CaptureRouteServiceResponse(res *http.Response)

func (*CompositeReporter) CaptureRoutingRequest

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

func (*CompositeReporter) CaptureRoutingResponse

func (c *CompositeReporter) CaptureRoutingResponse(statusCode int)

func (*CompositeReporter) CaptureRoutingResponseLatency

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

func (*CompositeReporter) CaptureWebSocketFailure

func (c *CompositeReporter) CaptureWebSocketFailure()

func (*CompositeReporter) CaptureWebSocketUpdate

func (c *CompositeReporter) CaptureWebSocketUpdate()

type MetricsReporter

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

func NewMetricsReporter

func NewMetricsReporter(sender metrics.MetricSender, batcher metrics.MetricBatcher) *MetricsReporter

func (*MetricsReporter) CaptureBadGateway

func (m *MetricsReporter) CaptureBadGateway()

func (*MetricsReporter) CaptureBadRequest

func (m *MetricsReporter) CaptureBadRequest()

func (*MetricsReporter) CaptureLookupTime

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

func (*MetricsReporter) CaptureRegistryMessage

func (m *MetricsReporter) CaptureRegistryMessage(msg ComponentTagged)

func (*MetricsReporter) CaptureRouteServiceResponse

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

func (*MetricsReporter) CaptureRouteStats

func (m *MetricsReporter) CaptureRouteStats(totalRoutes int, msSinceLastUpdate 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, 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()

type ProxyReporter

type ProxyReporter interface {
	CaptureBadRequest()
	CaptureBadGateway()
	CaptureRoutingRequest(b *route.Endpoint)
	CaptureRoutingResponse(statusCode int)
	CaptureRoutingResponseLatency(b *route.Endpoint, d time.Duration)
	CaptureRouteServiceResponse(res *http.Response)
	CaptureWebSocketUpdate()
	CaptureWebSocketFailure()
}

type RouteRegistryReporter

type RouteRegistryReporter interface {
	CaptureRouteStats(totalRoutes int, msSinceLastUpdate uint64)
	CaptureLookupTime(t time.Duration)
	CaptureRegistryMessage(msg ComponentTagged)
	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