baseemitter

Documentation

Index

• func TelegrafToSFXMetricType(m telegraf.Metric) (datapoint.MetricType, string)
• type BaseEmitter
  • func NewEmitter(Output types.Output, Logger log.FieldLogger) *BaseEmitter
  • func (b *BaseEmitter) AddDebug(deb string, args ...interface{})
  • func (b *BaseEmitter) AddError(err error)
  • func (b *BaseEmitter) AddMeasurementTransformation(f func(telegraf.Metric) error)
  • func (b *BaseEmitter) AddMeasurementTransformations(fns []func(telegraf.Metric) error)
  • func (b *BaseEmitter) AddMetric(m telegraf.Metric)
  • func (b *BaseEmitter) AddMetricNameTransformation(f func(string) string)
  • func (b *BaseEmitter) AddMetricNameTransformations(fns []func(string) string)
  • func (b *BaseEmitter) AddTag(key string, val string)
  • func (b *BaseEmitter) AddTags(tags map[string]string)
  • func (b *BaseEmitter) ExcludeData(names []string)
  • func (b *BaseEmitter) ExcludeDatum(name string)
  • func (b *BaseEmitter) FilterTags(key string, value string) bool
  • func (b *BaseEmitter) GetMetricName(metricName string, field string) string
  • func (b *BaseEmitter) IncludeEvent(name string)
  • func (b *BaseEmitter) IncludeEvents(names []string)
  • func (b *BaseEmitter) Included(name string) bool
  • func (b *BaseEmitter) IsExcluded(name string) bool
  • func (b *BaseEmitter) OmitTag(tag string)
  • func (b *BaseEmitter) OmitTags(tags []string)
  • func (b *BaseEmitter) RenameMetric(original string, override string)
  • func (b *BaseEmitter) RenameMetrics(mappings map[string]string)
  • func (b *BaseEmitter) SetOmitOrignalMetricType(in bool)
  • func (b *BaseEmitter) TransformMeasurement(m telegraf.Metric)

Functions

func TelegrafToSFXMetricType

func TelegrafToSFXMetricType(m telegraf.Metric) (datapoint.MetricType, string)

TelegrafToSFXMetricType returns the signalfx metric type for a telegraf metric

Types

type BaseEmitter

type BaseEmitter struct {
	Output types.Output
	Logger log.FieldLogger
	// contains filtered or unexported fields
}

BaseEmitter immediately converts a telegraf measurement into datapoints and sends them through Output

func NewEmitter

func NewEmitter(Output types.Output, Logger log.FieldLogger) *BaseEmitter

NewEmitter returns a new BaseEmitter

func (*BaseEmitter) AddDebug

func (b *BaseEmitter) AddDebug(deb string, args ...interface{})

AddDebug logs a debug statement

func (*BaseEmitter) AddError

func (b *BaseEmitter) AddError(err error)

AddError handles errors reported to a telegraf accumulator

func (*BaseEmitter) AddMeasurementTransformation

func (b *BaseEmitter) AddMeasurementTransformation(f func(telegraf.Metric) error)

AddMeasurementTransformation adds a function to the list of functions the emitter will pass an incoming measurement through. This is useful for manipulating tags and fields before the measurement is converted to a SignalFx datapoint.

func (*BaseEmitter) AddMeasurementTransformations

func (b *BaseEmitter) AddMeasurementTransformations(fns []func(telegraf.Metric) error)

AddMeasurementTransformations a list of functions to the list of functions the emitter will pass an incoming measurement through. This is useful for manipulating tags and fields before the measurement is converted to a SignalFx datapoint.

func (*BaseEmitter) AddMetric

func (b *BaseEmitter) AddMetric(m telegraf.Metric)

AddMetric parses metrics from telegraf and emits them through Output

func (*BaseEmitter) AddMetricNameTransformation

func (b *BaseEmitter) AddMetricNameTransformation(f func(string) string)

AddMetricNameTransformation adds a function for mutating metric names. GetMetricNames() will invoke each of the transformation functions after the metric name is parsed from the incoming measurement.

func (*BaseEmitter) AddMetricNameTransformations

func (b *BaseEmitter) AddMetricNameTransformations(fns []func(string) string)

AddMetricNameTransformations adds a list of functions for mutating metric names. GetMetricNames() will invoke each of the transformation functions after the metric name is parsed from the incoming measurement.

func (*BaseEmitter) AddTag

func (b *BaseEmitter) AddTag(key string, val string)

AddTag adds a key/value pair to all measurement tags. If a key conflicts the key value pair in AddTag will override the original key on the measurement

func (*BaseEmitter) AddTags

func (b *BaseEmitter) AddTags(tags map[string]string)

AddTags adds a map of key value pairs to all measurement tags. If a key conflicts the key value pair in AddTags will override the original key on the measurement.

func (*BaseEmitter) ExcludeData

func (b *BaseEmitter) ExcludeData(names []string)

ExcludeData adds a list of names the list of metrics and events to exclude

func (*BaseEmitter) ExcludeDatum

func (b *BaseEmitter) ExcludeDatum(name string)

ExcludeDatum adds a name to the list of metrics and events to exclude

func (*BaseEmitter) FilterTags

func (b *BaseEmitter) FilterTags(key string, value string) bool

FilterTags - filter function for util.CloneAndFilterStringMapWithFunc() it returns true if the supplied key is not in the omittedTags map

func (*BaseEmitter) GetMetricName

func (b *BaseEmitter) GetMetricName(metricName string, field string) string

GetMetricName parses the metric name and takes name overrides into account if a name is overridden it will not have transformations applied to it

func (*BaseEmitter) IncludeEvent

func (b *BaseEmitter) IncludeEvent(name string)

IncludeEvent registers an event name to include during emission. We disable all events by default because Telegraf has some junk events.

func (*BaseEmitter) IncludeEvents

func (b *BaseEmitter) IncludeEvents(names []string)

IncludeEvents registers a list of event names to include during emission. We disable all events by default because Telegraf has some junk events.

func (*BaseEmitter) Included

func (b *BaseEmitter) Included(name string) bool

Included - checks if events should be included during emission. We disable all events by default because Telegraf has some junk events.

func (*BaseEmitter) IsExcluded

func (b *BaseEmitter) IsExcluded(name string) bool

IsExcluded - checks if events or metrics should be excluded from emission

func (*BaseEmitter) OmitTag

func (b *BaseEmitter) OmitTag(tag string)

OmitTag adds a tag to the list of tags to remove from measurements

func (*BaseEmitter) OmitTags

func (b *BaseEmitter) OmitTags(tags []string)

OmitTags adds a list of tags the list of tags to remove from measurements

func (*BaseEmitter) RenameMetric

func (b *BaseEmitter) RenameMetric(original string, override string)

RenameMetric adds a mapping to rename a metric by it's name

func (*BaseEmitter) RenameMetrics

func (b *BaseEmitter) RenameMetrics(mappings map[string]string)

RenameMetrics takes a map of metric name overrides map[original]override

func (*BaseEmitter) SetOmitOrignalMetricType

func (b *BaseEmitter) SetOmitOrignalMetricType(in bool)

SetOmitOrignalMetricType accepts a boolean to indicate whether the emitter should add the original metric type or not to each metric

func (*BaseEmitter) TransformMeasurement

func (b *BaseEmitter) TransformMeasurement(m telegraf.Metric)

TransformMeasurement applies all measurementTransformations to the supplied measurement