internal_models

Documentation

Index

• Constants
• type Filter
  • 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) *RunningOutput
  • func (ro *RunningOutput) AddMetric(metric telegraf.Metric)
  • func (ro *RunningOutput) Write() error
• type TagFilter

Constants

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
)

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

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
	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.

type TagFilter

type TagFilter struct {
	Name   string
	Filter []string
}

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