Documentation
¶
Index ¶
- Variables
- type Prometheus
- func (p *Prometheus) IncResourceAddEventProcessedError(handler string)
- func (p *Prometheus) IncResourceAddEventProcessedSuccess(handler string)
- func (p *Prometheus) IncResourceAddEventQueued(handler string)
- func (p *Prometheus) IncResourceDeleteEventProcessedError(handler string)
- func (p *Prometheus) IncResourceDeleteEventProcessedSuccess(handler string)
- func (p *Prometheus) IncResourceDeleteEventQueued(handler string)
- func (p *Prometheus) ObserveDurationResourceAddEventProcessedError(handler string, start time.Time)
- func (p *Prometheus) ObserveDurationResourceAddEventProcessedSuccess(handler string, start time.Time)
- func (p *Prometheus) ObserveDurationResourceDeleteEventProcessedError(handler string, start time.Time)
- func (p *Prometheus) ObserveDurationResourceDeleteEventProcessedSuccess(handler string, start time.Time)
- type Recorder
Constants ¶
This section is empty.
Variables ¶
var Dummy = &dummy{}
Dummy is a dummy stats recorder.
Functions ¶
This section is empty.
Types ¶
type Prometheus ¶
type Prometheus struct {
// contains filtered or unexported fields
}
Prometheus implements the metrics recording in a prometheus registry.
func NewPrometheus ¶
func NewPrometheus(namespace string, registry prometheus.Registerer) *Prometheus
NewPrometheus returns a new Prometheus metrics backend with metrics prefixed by the namespace.
func NewPrometheusWithBuckets ¶
func NewPrometheusWithBuckets(buckets []float64, namespace string, registry prometheus.Registerer) *Prometheus
NewPrometheusWithBuckets returns a new Prometheus metrics backend with metrics prefixed by the namespace and with custom buckets for the duration/latency metrics. This kind should be used when the default buckets don't work. This could happen when the time to process an event is not on the range of 5ms-10s duration. Check https://godoc.org/github.com/prometheus/client_golang/prometheus#pkg-variables
func (*Prometheus) IncResourceAddEventProcessedError ¶
func (p *Prometheus) IncResourceAddEventProcessedError(handler string)
IncResourceAddEventProcessedError satisfies metrics.Recorder interface.
func (*Prometheus) IncResourceAddEventProcessedSuccess ¶
func (p *Prometheus) IncResourceAddEventProcessedSuccess(handler string)
IncResourceAddEventProcessedSuccess satisfies metrics.Recorder interface.
func (*Prometheus) IncResourceAddEventQueued ¶
func (p *Prometheus) IncResourceAddEventQueued(handler string)
IncResourceAddEventQueued satisfies metrics.Recorder interface.
func (*Prometheus) IncResourceDeleteEventProcessedError ¶
func (p *Prometheus) IncResourceDeleteEventProcessedError(handler string)
IncResourceDeleteEventProcessedError satisfies metrics.Recorder interface.
func (*Prometheus) IncResourceDeleteEventProcessedSuccess ¶
func (p *Prometheus) IncResourceDeleteEventProcessedSuccess(handler string)
IncResourceDeleteEventProcessedSuccess satisfies metrics.Recorder interface.
func (*Prometheus) IncResourceDeleteEventQueued ¶
func (p *Prometheus) IncResourceDeleteEventQueued(handler string)
IncResourceDeleteEventQueued satisfies metrics.Recorder interface.
func (*Prometheus) ObserveDurationResourceAddEventProcessedError ¶
func (p *Prometheus) ObserveDurationResourceAddEventProcessedError(handler string, start time.Time)
ObserveDurationResourceAddEventProcessedError satisfies metrics.Recorder interface.
func (*Prometheus) ObserveDurationResourceAddEventProcessedSuccess ¶
func (p *Prometheus) ObserveDurationResourceAddEventProcessedSuccess(handler string, start time.Time)
ObserveDurationResourceAddEventProcessedSuccess satisfies metrics.Recorder interface.
func (*Prometheus) ObserveDurationResourceDeleteEventProcessedError ¶
func (p *Prometheus) ObserveDurationResourceDeleteEventProcessedError(handler string, start time.Time)
ObserveDurationResourceDeleteEventProcessedError satisfies metrics.Recorder interface.
func (*Prometheus) ObserveDurationResourceDeleteEventProcessedSuccess ¶
func (p *Prometheus) ObserveDurationResourceDeleteEventProcessedSuccess(handler string, start time.Time)
ObserveDurationResourceDeleteEventProcessedSuccess satisfies metrics.Recorder interface.
type Recorder ¶
type Recorder interface {
// IncResourceAddEvent increments in one the metric records of a queued add
// event in a resource.
IncResourceAddEventQueued(handler string)
// IncResourceDeleteEvent increments in one the metric records of a queued delete
// event in a resource.
IncResourceDeleteEventQueued(handler string)
// IncResourceAddEventProcessedSuccess increments in one the metric records of a
// processed add event in success.
IncResourceAddEventProcessedSuccess(handler string)
// IncResourceAddEventProcessedError increments in one the metric records of a
// processed add event in error.
IncResourceAddEventProcessedError(handler string)
// IncResourceDeleteEventProcessedSuccess increments in one the metric records of a
// processed deleteevent in success.
IncResourceDeleteEventProcessedSuccess(handler string)
// IncResourceDeleteEventProcessedError increments in one the metric records of a
// processed delete event in error.
IncResourceDeleteEventProcessedError(handler string)
// ObserveDurationResourceAddEventProcessedSuccess measures the duration it took to process
// until now a successful processed add event.
ObserveDurationResourceAddEventProcessedSuccess(handler string, start time.Time)
// ObserveDurationResourceAddEventProcessedError measures the duration it took to process
// until now a failed processed add event.
ObserveDurationResourceAddEventProcessedError(handler string, start time.Time)
// ObserveDurationResourceAddEventProcessedSuccess measures the duration it took to process
// until now a successful processed delete event.
ObserveDurationResourceDeleteEventProcessedSuccess(handler string, start time.Time)
// ObserveDurationResourceAddEventProcessedError measures the duration it took to process
// until now a failed processed delete event.
ObserveDurationResourceDeleteEventProcessedError(handler string, start time.Time)
}
Recorder knows how to record metrics all over the application.