Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 ¶
func NewCloudWatchBackend(region string, dimensions []CloudWatchDimension, interval int64, enableHighResolution bool) *CloudWatchBackend
NewCloudWatchBackend returns a new CloudWatchBackend with optional dimensions
type CloudWatchDimension ¶
CloudWatchDimension is a dimension to add to metrics
func ParseCloudWatchDimensions ¶
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 ¶
func NewNewRelicBackend(appName string, licenseKey string) (*NewRelicBackend, error)
NewNewRelicBackend returns a backend for New Relic Where appName is your desired application name in New Relic
and licenseKey is your New Relic license key
func (*NewRelicBackend) Close ¶
func (nr *NewRelicBackend) Close() error
Close by shutting down NR client
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 and registered in NewPrometheusBackend.
Note: these metrics are not unique to a cluster / queue, as these labels are added to the value when it is set.
func NewPrometheusBackend ¶
func NewPrometheusBackend() *Prometheus
NewPrometheusBackend creates an instance of Prometheus and creates and registers all the metrics gauges. Because Prometheus metrics must be unique, it manages a singleton instance rather than creating a new backend for each call.
func (*Prometheus) Collect ¶
func (p *Prometheus) Collect(r *collector.Result) error
Collect receives a set of metrics from the agent and updates the gauges.
Note: This is called once per agent token per interval
func (*Prometheus) Serve ¶
func (p *Prometheus) Serve(path, addr string)
Serve runs a Prometheus metrics HTTP server.
type StackDriverBackend ¶
type StackDriverBackend struct {
// contains filtered or unexported fields
}
StackDriverBackend sends metrics to GCP Stackdriver
func NewStackDriverBackend ¶
func NewStackDriverBackend(gcpProjectID string) (*StackDriverBackend, error)
NewStackDriverBackend returns a new StackDriverBackend for the specified project
Source Files