Documentation
¶
Index ¶
- Constants
- type Filter
- func (f *Filter) CompileFilter() error
- func (f *Filter) FilterTags(tags map[string]string)
- func (f *Filter) ShouldFieldsPass(key string) bool
- func (f *Filter) ShouldMetricPass(metric telegraf.Metric) bool
- func (f *Filter) ShouldNamePass(key string) bool
- func (f *Filter) ShouldTagsPass(tags map[string]string) bool
- type InputConfig
- type OutputConfig
- type RunningInput
- type RunningOutput
- type TagFilter
Constants ¶
const ( // Default size of metrics batch size. DEFAULT_METRIC_BATCH_SIZE = 1000 // Default number of metrics kept. It should be a multiple of batch size. DEFAULT_METRIC_BUFFER_LIMIT = 10000 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Filter ¶
type Filter struct {
NameDrop []string
NamePass []string
FieldDrop []string
FieldPass []string
TagDrop []TagFilter
TagPass []TagFilter
TagExclude []string
TagInclude []string
IsActive bool
// contains filtered or unexported fields
}
Filter containing drop/pass and tagdrop/tagpass rules
func (*Filter) CompileFilter ¶
Compile all Filter lists into filter.Filter objects.
func (*Filter) FilterTags ¶ added in v0.7.0
Apply TagInclude and TagExclude filters. modifies the tags map in-place.
func (*Filter) ShouldFieldsPass ¶ added in v0.7.0
ShouldFieldsPass returns true if the metric should pass, false if should drop based on the drop/pass filter parameters
func (*Filter) ShouldNamePass ¶
ShouldFieldsPass returns true if the metric should pass, false if should drop based on the drop/pass filter parameters
type InputConfig ¶
type InputConfig struct {
Name string
NameOverride string
MeasurementPrefix string
MeasurementSuffix string
Tags map[string]string
Filter Filter
Interval time.Duration
}
InputConfig containing a name, interval, and filter
type OutputConfig ¶
OutputConfig containing name and filter
type RunningInput ¶
type RunningInput struct {
Name string
Input telegraf.Input
Config *InputConfig
}
type RunningOutput ¶
type RunningOutput struct {
Name string
Output telegraf.Output
Config *OutputConfig
Quiet bool
MetricBufferLimit int
MetricBatchSize int
// contains filtered or unexported fields
}
RunningOutput contains the output configuration
func NewRunningOutput ¶
func NewRunningOutput( name string, output telegraf.Output, conf *OutputConfig, batchSize int, bufferLimit int, ) *RunningOutput
func (*RunningOutput) AddMetric ¶
func (ro *RunningOutput) AddMetric(metric telegraf.Metric)
AddMetric adds a metric to the output. This function can also write cached points if FlushBufferWhenFull is true.
func (*RunningOutput) Write ¶
func (ro *RunningOutput) Write() error
Write writes all cached points to this output.
Source Files