models

package

Go to main page

Versions in this module

v1

v1.14.5

Jun 30, 2020

v1.14.4

Jun 9, 2020

v1.14.3

May 19, 2020

v1.14.2

Apr 28, 2020

v1.14.1

Apr 14, 2020

v1.14.0

Mar 26, 2020

Changes in this version

+ const DEFAULT_METRIC_BATCH_SIZE

+ const DEFAULT_METRIC_BUFFER_LIMIT

+ var AgentMetricsDropped = selfstat.Register("agent", "metrics_dropped", map[string]string{})

+ var AgentMetricsWritten = selfstat.Register("agent", "metrics_written", map[string]string{})

+ var GlobalGatherErrors = selfstat.Register("agent", "gather_errors", map[string]string{})

+ var GlobalMetricsGathered = selfstat.Register("agent", "metrics_gathered", map[string]string{})

+ type AggregatorConfig struct

+ Alias string

+ Delay time.Duration

+ DropOriginal bool

+ Filter Filter

+ Grace time.Duration

+ MeasurementPrefix string

+ MeasurementSuffix string

+ Name string

+ NameOverride string

+ Period time.Duration

+ Tags map[string]string

+ type Buffer struct

+ BufferLimit selfstat.Stat

+ BufferSize selfstat.Stat

+ MetricsAdded selfstat.Stat

+ MetricsDropped selfstat.Stat

+ MetricsWritten selfstat.Stat

+ func NewBuffer(name string, alias string, capacity int) *Buffer

+ func (b *Buffer) Accept(batch []telegraf.Metric)

+ func (b *Buffer) Add(metrics ...telegraf.Metric) int

+ func (b *Buffer) Batch(batchSize int) []telegraf.Metric

+ func (b *Buffer) Len() int

+ func (b *Buffer) Reject(batch []telegraf.Metric)

type Filter

+ FieldDrop []string

+ FieldPass []string

+ NameDrop []string

+ NamePass []string

+ TagExclude []string

+ TagInclude []string

+ func (f *Filter) Compile() error

+ func (f *Filter) Modify(metric telegraf.Metric)

+ func (f *Filter) Select(metric telegraf.Metric) bool

type InputConfig

+ Alias string

+ type Logger struct

+ Name string

+ OnErrs []func()

+ func NewLogger(pluginType, name, alias string) *Logger

+ func (l *Logger) Debug(args ...interface{})

+ func (l *Logger) Debugf(format string, args ...interface{})

+ func (l *Logger) Error(args ...interface{})

+ func (l *Logger) Errorf(format string, args ...interface{})

+ func (l *Logger) Info(args ...interface{})

+ func (l *Logger) Infof(format string, args ...interface{})

+ func (l *Logger) OnErr(f func())

+ func (l *Logger) Warn(args ...interface{})

+ func (l *Logger) Warnf(format string, args ...interface{})

type OutputConfig

+ Alias string

+ FlushInterval time.Duration

+ FlushJitter *time.Duration

+ MetricBatchSize int

+ MetricBufferLimit int

+ NameOverride string

+ NamePrefix string

+ NameSuffix string

+ type ProcessorConfig struct

+ Alias string

+ Filter Filter

+ Name string

+ Order int64

+ type RunningAggregator struct

+ Aggregator telegraf.Aggregator

+ Config *AggregatorConfig

+ MetricsDropped selfstat.Stat

+ MetricsFiltered selfstat.Stat

+ MetricsPushed selfstat.Stat

+ PushTime selfstat.Stat

+ func NewRunningAggregator(aggregator telegraf.Aggregator, config *AggregatorConfig) *RunningAggregator

+ func (r *RunningAggregator) Add(m telegraf.Metric) bool

+ func (r *RunningAggregator) EndPeriod() time.Time

+ func (r *RunningAggregator) Init() error

+ func (r *RunningAggregator) Log() telegraf.Logger

+ func (r *RunningAggregator) LogName() string

+ func (r *RunningAggregator) MakeMetric(metric telegraf.Metric) telegraf.Metric

+ func (r *RunningAggregator) Period() time.Duration

+ func (r *RunningAggregator) Push(acc telegraf.Accumulator)

+ func (r *RunningAggregator) UpdateWindow(start, until time.Time)

type RunningInput

+ GatherTime selfstat.Stat

+ MetricsGathered selfstat.Stat

+ func NewRunningInput(input telegraf.Input, config *InputConfig) *RunningInput

+ func (r *RunningInput) Gather(acc telegraf.Accumulator) error

+ func (r *RunningInput) Init() error

+ func (r *RunningInput) Log() telegraf.Logger

+ func (r *RunningInput) LogName() string

+ func (r *RunningInput) MakeMetric(metric telegraf.Metric) telegraf.Metric

+ func (r *RunningInput) SetDefaultTags(tags map[string]string)

type RunningOutput

+ BatchReady chan time.Time

+ MetricBatchSize int

+ MetricBufferLimit int

+ MetricsFiltered selfstat.Stat

+ WriteTime selfstat.Stat

+ func (r *RunningOutput) Close()

+ func (r *RunningOutput) Init() error

+ func (r *RunningOutput) Log() telegraf.Logger

+ func (r *RunningOutput) LogBufferStatus()

+ func (r *RunningOutput) LogName() string

+ func (ro *RunningOutput) AddMetric(metric telegraf.Metric)

+ func (ro *RunningOutput) WriteBatch() error

+ type RunningProcessor struct

+ Config *ProcessorConfig

+ Processor telegraf.Processor

+ func NewRunningProcessor(processor telegraf.Processor, config *ProcessorConfig) *RunningProcessor

+ func (r *RunningProcessor) Init() error

+ func (r *RunningProcessor) Log() telegraf.Logger

+ func (rp *RunningProcessor) Apply(in ...telegraf.Metric) []telegraf.Metric

+ type RunningProcessors []*RunningProcessor

+ func (rp RunningProcessors) Len() int

+ func (rp RunningProcessors) Less(i, j int) bool

+ func (rp RunningProcessors) Swap(i, j int)

v1.14.0-rc1

Mar 18, 2020

v0

v0.10.1

Jan 27, 2016

Changes in this version

+ const DEFAULT_POINT_BUFFER_LIMIT

+ type Filter struct

+ Drop []string

+ IsActive bool

+ Pass []string

+ TagDrop []TagFilter

+ TagPass []TagFilter

+ func (f Filter) ShouldPass(key string) bool

+ func (f Filter) ShouldPointPass(point *client.Point) bool

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

+ type InputConfig struct

+ Filter Filter

+ Interval time.Duration

+ MeasurementPrefix string

+ MeasurementSuffix string

+ Name string

+ NameOverride string

+ Tags map[string]string

+ type OutputConfig struct

+ Filter Filter

+ Name string

+ type RunningInput struct

+ Config *InputConfig

+ Input inputs.Input

+ Name string

+ type RunningOutput struct

+ Config *OutputConfig

+ Name string

+ Output outputs.Output

+ PointBufferLimit int

+ Quiet bool

+ func NewRunningOutput(name string, output outputs.Output, conf *OutputConfig) *RunningOutput

+ func (ro *RunningOutput) AddPoint(point *client.Point)

+ func (ro *RunningOutput) Write() error

+ type TagFilter struct

+ Filter []string

+ Name string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL