models

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
  • func NewRunningOutput(name string, output telegraf.Output, conf *OutputConfig, batchSize int, ...) *RunningOutput
  • func (ro *RunningOutput) AddMetric(metric telegraf.Metric)
  • func (ro *RunningOutput) Write() error
• 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
)

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

func (f *Filter) CompileFilter() error

Compile all Filter lists into filter.Filter objects.

func (*Filter) FilterTags

func (f *Filter) FilterTags(tags map[string]string)

Apply TagInclude and TagExclude filters. modifies the tags map in-place.

func (*Filter) ShouldFieldsPass

func (f *Filter) ShouldFieldsPass(key string) bool

ShouldFieldsPass returns true if the metric should pass, false if should drop based on the drop/pass filter parameters

func (*Filter) ShouldMetricPass

func (f *Filter) ShouldMetricPass(metric telegraf.Metric) bool

func (*Filter) ShouldNamePass

func (f *Filter) ShouldNamePass(key string) bool

ShouldFieldsPass returns true if the metric should pass, false if should drop based on the drop/pass filter parameters

func (*Filter) ShouldTagsPass

func (f *Filter) ShouldTagsPass(tags map[string]string) bool

ShouldTagsPass returns true if the metric should pass, false if should drop based on the tagdrop/tagpass 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

type OutputConfig struct {
	Name   string
	Filter Filter
}

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.

type TagFilter

type TagFilter struct {
	Name   string
	Filter []string
	// contains filtered or unexported fields
}

TagFilter is the name of a tag, and the values on which to filter