helpers

Documentation

Index

• type RequestMetrics
• type RequestMetricsNotifier
  • func NewRequestMetricsNotifier(logger lager.Logger, clock clock.Clock, ...) *RequestMetricsNotifier
  • func (notifier *RequestMetricsNotifier) DecrementRequestsInFlightCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) IncrementRequestsCancelledCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) IncrementRequestsFailedCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) IncrementRequestsInFlightCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) IncrementRequestsStartedCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) IncrementRequestsSucceededCounter(requestType string, delta int)
  • func (notifier *RequestMetricsNotifier) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (notifier *RequestMetricsNotifier) UpdateLatency(requestType string, dur time.Duration)

Types

type RequestMetrics

type RequestMetrics interface {
	IncrementRequestsStartedCounter(requestType string, delta int)
	IncrementRequestsSucceededCounter(requestType string, delta int)
	IncrementRequestsFailedCounter(requestType string, delta int)
	IncrementRequestsInFlightCounter(requestType string, delta int)
	DecrementRequestsInFlightCounter(requestType string, delta int)
	IncrementRequestsCancelledCounter(requestType string, delta int)
	UpdateLatency(requestType string, dur time.Duration)
}

type RequestMetricsNotifier

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

func NewRequestMetricsNotifier

func NewRequestMetricsNotifier(logger lager.Logger, clock clock.Clock, metronClient loggingclient.IngressClient, metricsInterval time.Duration, requestTypes []string) *RequestMetricsNotifier

func (*RequestMetricsNotifier) DecrementRequestsInFlightCounter

func (notifier *RequestMetricsNotifier) DecrementRequestsInFlightCounter(requestType string, delta int)

func (*RequestMetricsNotifier) IncrementRequestsCancelledCounter

func (notifier *RequestMetricsNotifier) IncrementRequestsCancelledCounter(requestType string, delta int)

func (*RequestMetricsNotifier) IncrementRequestsFailedCounter

func (notifier *RequestMetricsNotifier) IncrementRequestsFailedCounter(requestType string, delta int)

func (*RequestMetricsNotifier) IncrementRequestsInFlightCounter

func (notifier *RequestMetricsNotifier) IncrementRequestsInFlightCounter(requestType string, delta int)

func (*RequestMetricsNotifier) IncrementRequestsStartedCounter

func (notifier *RequestMetricsNotifier) IncrementRequestsStartedCounter(requestType string, delta int)

func (*RequestMetricsNotifier) IncrementRequestsSucceededCounter

func (notifier *RequestMetricsNotifier) IncrementRequestsSucceededCounter(requestType string, delta int)

func (*RequestMetricsNotifier) Run

func (notifier *RequestMetricsNotifier) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*RequestMetricsNotifier) UpdateLatency

func (notifier *RequestMetricsNotifier) UpdateLatency(requestType string, dur time.Duration)