metric

Documentation

Index

• func EnableDebugFinalizer()
• func FromMetric(other telegraf.Metric) telegraf.Metric
• func New(name string, tags map[string]string, fields map[string]interface{}, ...) (telegraf.Metric, error)
• func WithGroupTracking(metric []telegraf.Metric, fn NotifyFunc) ([]telegraf.Metric, telegraf.TrackingID)
• func WithTracking(metric telegraf.Metric, fn NotifyFunc) (telegraf.Metric, telegraf.TrackingID)
• type NotifyFunc
• type SeriesGrouper
  • func NewSeriesGrouper() *SeriesGrouper
  • func (g *SeriesGrouper) Add(measurement string, tags map[string]string, tm time.Time, field string, ...) error
  • func (g *SeriesGrouper) Metrics() []telegraf.Metric

Functions

func EnableDebugFinalizer

func EnableDebugFinalizer()

func FromMetric

func FromMetric(other telegraf.Metric) telegraf.Metric

FromMetric returns a deep copy of the metric with any tracking information removed.

func New

func New(
	name string,
	tags map[string]string,
	fields map[string]interface{},
	tm time.Time,
	tp ...telegraf.ValueType,
) (telegraf.Metric, error)

func WithGroupTracking

func WithGroupTracking(metric []telegraf.Metric, fn NotifyFunc) ([]telegraf.Metric, telegraf.TrackingID)

WithBatchTracking adds tracking to the metrics and registers the notify function to be called when processing is complete.

func WithTracking

func WithTracking(metric telegraf.Metric, fn NotifyFunc) (telegraf.Metric, telegraf.TrackingID)

WithTracking adds tracking to the metric and registers the notify function to be called when processing is complete.

Types

type NotifyFunc

type NotifyFunc = func(track telegraf.DeliveryInfo)

NotifyFunc is called when a tracking metric is done being processed with the tracking information.

type SeriesGrouper

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

func NewSeriesGrouper

func NewSeriesGrouper() *SeriesGrouper

NewSeriesGrouper returns a type that can be used to group fields by series and time, so that fields which share these values will be combined into a single telegraf.Metric.

This is useful to build telegraf.Metric's when all fields for a series are not available at once.

ex: - cpu,host=localhost usage_time=42 - cpu,host=localhost idle_time=42 + cpu,host=localhost idle_time=42,usage_time=42

func (*SeriesGrouper) Add

func (g *SeriesGrouper) Add(
	measurement string,
	tags map[string]string,
	tm time.Time,
	field string,
	fieldValue interface{},
) error

Add adds a field key and value to the series.

func (*SeriesGrouper) Metrics

func (g *SeriesGrouper) Metrics() []telegraf.Metric

Metrics returns the metrics grouped by series and time.