backend

type Backend ¶

type Backend interface {
	Collect(r *collector.Result) error
}

Backend is a receiver of metrics

type Closer ¶

type Closer interface {
	Close() error
}

Closer is an interface for backends that need to dispose of resources

type CloudWatchBackend ¶

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

CloudWatchBackend sends metrics to AWS CloudWatch

func NewCloudWatchBackend(region string, dimensions []CloudWatchDimension, interval int64, enableHighResolution bool) *CloudWatchBackend

func (cb *CloudWatchBackend) Collect(r *collector.Result) error

type CloudWatchDimension ¶

type CloudWatchDimension struct {
	Key   string
	Value string
}

CloudWatchDimension is a dimension to add to metrics

func ParseCloudWatchDimensions(ds string) ([]CloudWatchDimension, error)

type NewRelicBackend ¶

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

NewRelicBackend sends metrics to New Relic Insights

func NewNewRelicBackend(appName string, licenseKey string) (*NewRelicBackend, error)

and licenseKey is your New Relic license key

func (nr *NewRelicBackend) Close() error

func (nr *NewRelicBackend) Collect(r *collector.Result) error

type Prometheus ¶

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

Prometheus this holds a list of prometheus gauges which have been created, one for each metric that we want to expose. These are created on the fly as we receive metrics from the agent.

Note: these metrics are not unique to a cluster / queue, as these labels are added to the value when it is set.

func NewPrometheusBackend() *Prometheus

func (p *Prometheus) Collect(r *collector.Result) error

func (p *Prometheus) Serve(path, addr string)

type StackDriverBackend ¶

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

StackDriverBackend sends metrics to GCP Stackdriver

func NewStackDriverBackend(gcpProjectID string) (*StackDriverBackend, error)

func (sd *StackDriverBackend) Collect(r *collector.Result) error

type StatsD ¶

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

StatsD sends metrics to StatsD (Datadog spec)

func NewStatsDBackend(host string, tagsSupported bool) (*StatsD, error)

func (cb *StatsD) Collect(r *collector.Result) error