Documentation
¶
Index ¶
- type Config
- type Recorder
- func (r Recorder) IncResourceEventQueued(ctx context.Context, controller string, isRequeue bool)
- func (r Recorder) ObserveResourceInQueueDuration(ctx context.Context, controller string, queuedAt time.Time)
- func (r Recorder) ObserveResourceProcessingDuration(ctx context.Context, controller string, success bool, ...)
- func (r Recorder) RegisterResourceQueueLengthFunc(controller string, f func(context.Context) int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Registerer is a prometheus registerer, e.g: prometheus.Registry.
// By default will use Prometheus default registry.
Registerer prometheus.Registerer
// InQueueBuckets sets custom buckets for the duration/latency items in queue metrics.
// Check https://godoc.org/github.com/prometheus/client_golang/prometheus#pkg-variables
InQueueBuckets []float64
// ProcessingBuckets sets custom buckets for the duration/latency processing metrics.
// Check https://godoc.org/github.com/prometheus/client_golang/prometheus#pkg-variables
ProcessingBuckets []float64
}
Config is the Recorder Config.
type Recorder ¶
type Recorder struct {
// contains filtered or unexported fields
}
Recorder implements the metrics recording in a prometheus registry.
func (Recorder) IncResourceEventQueued ¶
IncResourceEventQueued satisfies controller.MetricsRecorder interface.
func (Recorder) ObserveResourceInQueueDuration ¶
func (r Recorder) ObserveResourceInQueueDuration(ctx context.Context, controller string, queuedAt time.Time)
ObserveResourceInQueueDuration satisfies controller.MetricsRecorder interface.
Click to show internal directories.
Click to hide internal directories.