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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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.
Source Files