signalfx

README

SignalFx Sink

This sink sends Veneur metrics to SignalFx.

Configuration

See the various signalfx_* keys in example.yaml for all available configuration options.

Status

This sink is stable. This sink does not yet provide all of the functionality that SignalFx allows. Some of Veneur's primitives still need to be mapped to those of SignalFx.

Capabilities

Metrics

Enabled if signalfx_api_key is set to a non-empty value.

• Counters are counters.
• Gauges are gauges.

The following tags are mapped to SignalFx fields as follows:

• The configured Veneur hostname field is sent to SignalFx as the value from signalfx_hostname_tag.

TODO

• Does not handle events correctly yet, only copies timestamp, title and tags.
• SignalFx does not have a formal concept of per-metric hosts, so signalfx_hostname_tag may need some work.

Documentation

Index

• type DPClient
  • func NewClient(endpoint, apiKey string) DPClient
• type SignalFxSink
  • func NewSignalFxSink(hostnameTag string, hostname string, commonDimensions map[string]string, ...) (*SignalFxSink, error)
  • func (sfx *SignalFxSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error
  • func (sfx *SignalFxSink) FlushEventsChecks(ctx context.Context, events []samplers.UDPEvent, ...)
  • func (sfx *SignalFxSink) Name() string
  • func (sfx *SignalFxSink) SetExcludedTags(excludes []string)
  • func (sfx *SignalFxSink) Start(traceClient *trace.Client) error

Types

type DPClient

type DPClient dpsink.Sink

A DPClient is a client that can be used to submit signalfx data points to an upstream consumer. It wraps the dpsink.Sink interface.

func NewClient

func NewClient(endpoint, apiKey string) DPClient

NewClient constructs a new signalfx HTTP client for the given endpoint and API token.

type SignalFxSink

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

SignalFxSink is a MetricsSink implementation.

func NewSignalFxSink

func NewSignalFxSink(hostnameTag string, hostname string, commonDimensions map[string]string, log *logrus.Logger, client DPClient, varyBy string, perTagClients map[string]DPClient) (*SignalFxSink, error)

NewSignalFxSink creates a new SignalFx sink for metrics.

func (*SignalFxSink) Flush

func (sfx *SignalFxSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error

Flush sends metrics to SignalFx

func (*SignalFxSink) FlushEventsChecks

func (sfx *SignalFxSink) FlushEventsChecks(ctx context.Context, events []samplers.UDPEvent, checks []samplers.UDPServiceCheck)

FlushEventsChecks sends events to SignalFx. It does not support checks. It is also currently disabled.

func (*SignalFxSink) Name

func (sfx *SignalFxSink) Name() string

Name returns the name of this sink.

func (*SignalFxSink) SetExcludedTags

func (sfx *SignalFxSink) SetExcludedTags(excludes []string)

SetTagExcludes sets the excluded tag names. Any tags with the provided key (name) will be excluded.

func (*SignalFxSink) Start

func (sfx *SignalFxSink) Start(traceClient *trace.Client) error

Start begins the sink. For SignalFx this is a noop.