metrics

package
v0.4.7 Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2017 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Package metrics contains a type for aggregating and propagating metrics to various services based on configuration.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidMetricOutputType = errors.New("invalid metrics output type")
)

Errors for the metrics package.

View Source
var (
	ErrTimedOut = errors.New("timed out")
)

Errors for the HTTP type.

Functions

func Descriptions

func Descriptions() string

Descriptions returns a formatted string of collated descriptions of each type.

Types

type Config

type Config struct {
	Type    string        `json:"type" yaml:"type"`
	HTTP    HTTPConfig    `json:"http_server" yaml:"http_server"`
	Riemann RiemannConfig `json:"riemann" yaml:"riemann"`
	Statsd  StatsdConfig  `json:"statsd" yaml:"statsd"`
}

Config is the all encompassing configuration struct for all metric output types.

func NewConfig

func NewConfig() Config

NewConfig returns a configuration struct fully populated with default values.

type DudType

type DudType struct{}

DudType implements the Type interface but doesn't actual do anything.

func (DudType) Close

func (d DudType) Close() error

Close does nothing.

func (DudType) Decr

func (d DudType) Decr(path string, count int64) error

Decr does nothing.

func (DudType) Gauge

func (d DudType) Gauge(path string, value int64) error

Gauge does nothing.

func (DudType) Incr

func (d DudType) Incr(path string, count int64) error

Incr does nothing.

func (DudType) Timing

func (d DudType) Timing(path string, delta int64) error

Timing does nothing.

type HTTP

type HTTP struct {
	sync.Mutex
	// contains filtered or unexported fields
}

HTTP is an object with capability to hold internal stats as a JSON endpoint.

func (*HTTP) Close

func (h *HTTP) Close() error

Close stops the HTTP object from aggregating metrics and cleans up resources.

func (*HTTP) Decr

func (h *HTTP) Decr(stat string, value int64) error

Decr decrements a stat by a value.

func (*HTTP) Gauge

func (h *HTTP) Gauge(stat string, value int64) error

Gauge sets a stat as a gauge value.

func (*HTTP) Incr

func (h *HTTP) Incr(stat string, value int64) error

Incr increments a stat by a value.

func (*HTTP) JSONHandler

func (h *HTTP) JSONHandler() http.HandlerFunc

JSONHandler returns a handler for accessing metrics as a JSON blob.

func (*HTTP) Timing

func (h *HTTP) Timing(stat string, delta int64) error

Timing sets a stat representing a duration.

type HTTPConfig

type HTTPConfig struct {
	Prefix  string `json:"stats_prefix" yaml:"stats_prefix"`
	Address string `json:"address" yaml:"address"`
	Path    string `json:"path" yaml:"path"`
}

HTTPConfig contains config for the HTTP metrics type.

func NewHTTPConfig

func NewHTTPConfig() HTTPConfig

NewHTTPConfig creates an HTTPConfig struct with default values.

type Riemann

type Riemann struct {
	sync.Mutex

	Client *raidman.Client
	// contains filtered or unexported fields
}

Riemann is a Riemann client that supports the Type interface.

func (*Riemann) Close

func (r *Riemann) Close() error

Close will close the riemann client and stop batch uploading.

func (*Riemann) Decr

func (r *Riemann) Decr(stat string, value int64) error

Decr decrements a stat by a value.

func (*Riemann) Gauge

func (r *Riemann) Gauge(stat string, value int64) error

Gauge sets a stat as a gauge value.

func (*Riemann) Incr

func (r *Riemann) Incr(stat string, value int64) error

Incr increments a stat by a value.

func (*Riemann) Timing

func (r *Riemann) Timing(stat string, delta int64) error

Timing sets a stat representing a duration.

type RiemannConfig

type RiemannConfig struct {
	Server        string   `json:"server" yaml:"server"`
	TTL           float32  `json:"ttl" yaml:"ttl"`
	Tags          []string `json:"tags" yaml:"tags"`
	FlushInterval string   `json:"flush_interval" yaml:"flush_interval"`
	Prefix        string   `json:"prefix" yaml:"prefix"`
}

RiemannConfig contains configuration fields for a riemann service.

func NewRiemannConfig

func NewRiemannConfig() RiemannConfig

NewRiemannConfig creates a new riemann config with default values.

type Statsd

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

Statsd is a stats object with capability to hold internal stats as a JSON endpoint.

func (*Statsd) Close

func (h *Statsd) Close() error

Close stops the Statsd object from aggregating metrics and cleans up resources.

func (*Statsd) Decr

func (h *Statsd) Decr(stat string, value int64) error

Decr decrements a stat by a value.

func (*Statsd) Gauge

func (h *Statsd) Gauge(stat string, value int64) error

Gauge sets a stat as a gauge value.

func (*Statsd) Incr

func (h *Statsd) Incr(stat string, value int64) error

Incr increments a stat by a value.

func (*Statsd) Timing

func (h *Statsd) Timing(stat string, delta int64) error

Timing sets a stat representing a duration.

type StatsdConfig

type StatsdConfig struct {
	Address       string `json:"address" yaml:"address"`
	FlushPeriod   string `json:"flush_period" yaml:"flush_period"`
	MaxPacketSize int    `json:"max_packet_size" yaml:"max_packet_size"`
	Network       string `json:"network" yaml:"network"`
	Prefix        string `json:"prefix" yaml:"prefix"`
}

StatsdConfig is config for the Statsd metrics type.

func NewStatsdConfig

func NewStatsdConfig() StatsdConfig

NewStatsdConfig creates an StatsdConfig struct with default values.

type Type

type Type interface {
	// Incr increments a metric by an amount.
	Incr(path string, count int64) error

	// Decr decrements a metric by an amount.
	Decr(path string, count int64) error

	// Timing sets a timing metric.
	Timing(path string, delta int64) error

	// Gauge sets a gauge metric.
	Gauge(path string, value int64) error

	// Close stops aggregating stats and clean up resources.
	Close() error
}

Type is an interface for metrics aggregation.

func New

func New(conf Config) (Type, error)

New creates a metric output type based on a configuration.

func NewHTTP

func NewHTTP(config Config) (Type, error)

NewHTTP creates and returns a new HTTP object.

func NewRiemann

func NewRiemann(config Config) (Type, error)

NewRiemann creates a new riemann client.

func NewStatsd

func NewStatsd(config Config) (Type, error)

NewStatsd creates and returns a new Statsd object.

Jump to

Keyboard shortcuts

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