Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Default number of metrics kept between flushes. DEFAULT_METRIC_BUFFER_LIMIT = 1000 // Limit how many full metric buffers are kept due to failed writes. FULL_METRIC_BUFFERS_LIMIT = 100 )
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
IsActive bool
}
Filter containing drop/pass and tagdrop/tagpass rules
func (Filter) ShouldFieldsPass ¶
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
FlushBufferWhenFull bool
sync.Mutex
// contains filtered or unexported fields
}
func NewRunningOutput ¶
func NewRunningOutput( name string, output telegraf.Output, conf *OutputConfig, ) *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
Click to show internal directories.
Click to hide internal directories.