emitter

Documentation

Index

• type DogstatsDBConfig
  • func (config *DogstatsDBConfig) Description() string
  • func (config *DogstatsDBConfig) IsConfigured() bool
  • func (config *DogstatsDBConfig) NewEmitter() (metric.Emitter, error)
• type DogstatsdEmitter
  • func (emitter *DogstatsdEmitter) Emit(logger lager.Logger, event metric.Event)
• type InfluxDBConfig
  • func (config *InfluxDBConfig) Description() string
  • func (config *InfluxDBConfig) IsConfigured() bool
  • func (config *InfluxDBConfig) NewEmitter() (metric.Emitter, error)
• type InfluxDBEmitter
  • func (emitter *InfluxDBEmitter) Emit(logger lager.Logger, event metric.Event)
• type LagerConfig
  • func (config *LagerConfig) Description() string
  • func (config *LagerConfig) IsConfigured() bool
  • func (config *LagerConfig) NewEmitter() (metric.Emitter, error)
• type LagerEmitter
  • func (emitter *LagerEmitter) Emit(logger lager.Logger, event metric.Event)
• type NewRelicConfig
  • func (config *NewRelicConfig) Description() string
  • func (config *NewRelicConfig) IsConfigured() bool
  • func (config *NewRelicConfig) NewEmitter() (metric.Emitter, error)
• type NewRelicEmitter
  • func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event)
• type PrometheusConfig
  • func (config *PrometheusConfig) Description() string
  • func (config *PrometheusConfig) IsConfigured() bool
  • func (config *PrometheusConfig) NewEmitter() (metric.Emitter, error)
• type PrometheusEmitter
  • func (emitter *PrometheusEmitter) Emit(logger lager.Logger, event metric.Event)
• type RiemannConfig
  • func (config *RiemannConfig) Description() string
  • func (config *RiemannConfig) IsConfigured() bool
  • func (config *RiemannConfig) NewEmitter() (metric.Emitter, error)
• type RiemannEmitter
  • func (emitter *RiemannEmitter) Emit(logger lager.Logger, event metric.Event)

Types

type DogstatsDBConfig

type DogstatsDBConfig struct {
	Host   string `long:"datadog-agent-host" description:"Datadog agent host to expose dogstatsd metrics"`
	Port   string `long:"datadog-agent-port" description:"Datadog agent port to expose dogstatsd metrics"`
	Prefix string `long:"datadog-prefix" description:"Prefix for all metrics to easily find them in Datadog"`
}

func (*DogstatsDBConfig) Description

func (config *DogstatsDBConfig) Description() string

func (*DogstatsDBConfig) IsConfigured

func (config *DogstatsDBConfig) IsConfigured() bool

func (*DogstatsDBConfig) NewEmitter

func (config *DogstatsDBConfig) NewEmitter() (metric.Emitter, error)

type DogstatsdEmitter

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

func (*DogstatsdEmitter) Emit

func (emitter *DogstatsdEmitter) Emit(logger lager.Logger, event metric.Event)

type InfluxDBConfig

type InfluxDBConfig struct {
	URL string `long:"influxdb-url" description:"InfluxDB server address to emit points to."`

	Database string `long:"influxdb-database" description:"InfluxDB database to write points to."`

	Username string `long:"influxdb-username" description:"InfluxDB server username."`
	Password string `long:"influxdb-password" description:"InfluxDB server password."`

	InsecureSkipVerify bool `long:"influxdb-insecure-skip-verify" description:"Skip SSL verification when emitting to InfluxDB."`
}

func (*InfluxDBConfig) Description

func (config *InfluxDBConfig) Description() string

func (*InfluxDBConfig) IsConfigured

func (config *InfluxDBConfig) IsConfigured() bool

func (*InfluxDBConfig) NewEmitter

func (config *InfluxDBConfig) NewEmitter() (metric.Emitter, error)

type InfluxDBEmitter

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

func (*InfluxDBEmitter) Emit

func (emitter *InfluxDBEmitter) Emit(logger lager.Logger, event metric.Event)

type LagerConfig

type LagerConfig struct {
	Enabled bool `long:"emit-to-logs" description:"Emit metrics to logs."`
}

func (*LagerConfig) Description

func (config *LagerConfig) Description() string

func (*LagerConfig) IsConfigured

func (config *LagerConfig) IsConfigured() bool

func (*LagerConfig) NewEmitter

func (config *LagerConfig) NewEmitter() (metric.Emitter, error)

type LagerEmitter

type LagerEmitter struct{}

func (*LagerEmitter) Emit

func (emitter *LagerEmitter) Emit(logger lager.Logger, event metric.Event)

type NewRelicConfig

type NewRelicConfig struct {
	AccountID     string `long:"newrelic-account-id" description:"New Relic Account ID"`
	APIKey        string `long:"newrelic-api-key" description:"New Relic Insights API Key"`
	ServicePrefix string `long:"newrelic-service-prefix" default:"" description:"An optional prefix for emitted New Relic events"`
}

func (*NewRelicConfig) Description

func (config *NewRelicConfig) Description() string

func (*NewRelicConfig) IsConfigured

func (config *NewRelicConfig) IsConfigured() bool

func (*NewRelicConfig) NewEmitter

func (config *NewRelicConfig) NewEmitter() (metric.Emitter, error)

type NewRelicEmitter

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

func (*NewRelicEmitter) Emit

func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event)

type PrometheusConfig

type PrometheusConfig struct {
	BindIP   string `long:"prometheus-bind-ip" description:"IP to listen on to expose Prometheus metrics."`
	BindPort string `long:"prometheus-bind-port" description:"Port to listen on to expose Prometheus metrics."`
}

func (*PrometheusConfig) Description

func (config *PrometheusConfig) Description() string

func (*PrometheusConfig) IsConfigured

func (config *PrometheusConfig) IsConfigured() bool

func (*PrometheusConfig) NewEmitter

func (config *PrometheusConfig) NewEmitter() (metric.Emitter, error)

type PrometheusEmitter

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

func (*PrometheusEmitter) Emit

func (emitter *PrometheusEmitter) Emit(logger lager.Logger, event metric.Event)

Emit processes incoming metrics. In order to provide idiomatic Prometheus metrics, we'll have to convert the various Event types (differentiated by the less-than-ideal string Name field) into different Prometheus metrics.

type RiemannConfig

type RiemannConfig struct {
	Host string `long:"riemann-host"                  description:"Riemann server address to emit metrics to."`
	Port uint16 `long:"riemann-port"  default:"5555"  description:"Port of the Riemann server to emit metrics to."`

	ServicePrefix string `long:"riemann-service-prefix" default:"" description:"An optional prefix for emitted Riemann services"`

	Tags []string `long:"riemann-tag" description:"Tag to attach to emitted metrics. Can be specified multiple times." value-name:"TAG"`
}

func (*RiemannConfig) Description

func (config *RiemannConfig) Description() string

func (*RiemannConfig) IsConfigured

func (config *RiemannConfig) IsConfigured() bool

func (*RiemannConfig) NewEmitter

func (config *RiemannConfig) NewEmitter() (metric.Emitter, error)

type RiemannEmitter

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

func (*RiemannEmitter) Emit

func (emitter *RiemannEmitter) Emit(logger lager.Logger, event metric.Event)