Documentation
¶
Index ¶
- type RequestMetrics
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.