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 Builder
- func (m Builder) Accept()
- func (b *Builder) AddField(key string, value interface{})
- func (m Builder) AddPrefix(prefix string)
- func (m Builder) AddSuffix(suffix string)
- func (b *Builder) AddTag(key string, value string)
- func (m Builder) Copy() telegraf.Metric
- func (m Builder) Drop()
- func (m Builder) FieldList() []*telegraf.Field
- func (m Builder) Fields() map[string]interface{}
- func (m Builder) GetField(key string) (interface{}, bool)
- func (m Builder) GetTag(key string) (string, bool)
- func (m Builder) HasField(key string) bool
- func (m Builder) HasTag(key string) bool
- func (m Builder) HashID() uint64
- func (m Builder) IsAggregate() bool
- func (b *Builder) Metric() (telegraf.Metric, error)
- func (m Builder) Name() string
- func (m Builder) Reject()
- func (m Builder) RemoveField(key string)
- func (m Builder) RemoveTag(key string)
- func (b *Builder) Reset()
- func (m Builder) SetAggregate(b bool)
- func (b *Builder) SetName(name string)
- func (b *Builder) SetTime(tm time.Time)
- func (m Builder) String() string
- func (m Builder) TagList() []*telegraf.Tag
- func (m Builder) Tags() map[string]string
- func (m Builder) Time() time.Time
- func (m Builder) Type() telegraf.ValueType
- type NotifyFunc
- type SeriesGrouper
- type TimeFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnableDebugFinalizer ¶
func EnableDebugFinalizer()
func FromMetric ¶
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 Builder ¶
type Builder struct {
TimeFunc
TimePrecision time.Duration
// contains filtered or unexported fields
}
func NewBuilder ¶
func NewBuilder() *Builder
func (Builder) IsAggregate ¶
func (m Builder) IsAggregate() bool
func (Builder) RemoveField ¶
func (m Builder) RemoveField(key string)
func (Builder) SetAggregate ¶
func (m Builder) SetAggregate(b bool)
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