metrics

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2018 License: Apache-2.0 Imports: 2 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL