Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + const DefaultMetricBatchSize + const DefaultMetricBufferLimit + var AgentMetricsDropped = selfstat.Register("agent", "metrics_dropped", make(map[string]string)) + var AgentMetricsRejected = selfstat.Register("agent", "metrics_rejected", make(map[string]string)) + var AgentMetricsWritten = selfstat.Register("agent", "metrics_written", make(map[string]string)) + var GlobalGatherErrors = selfstat.Register("agent", "gather_errors", make(map[string]string)) + var GlobalGatherTimeouts = selfstat.Register("agent", "gather_timeouts", make(map[string]string)) + var GlobalMetricsGathered = selfstat.Register("agent", "metrics_gathered", make(map[string]string)) + func SetLoggerOnPlugin(i interface{}, logger telegraf.Logger) + func SetStatisticsOnPlugin(plugin interface{}, logger telegraf.Logger, tags map[string]string) + func ShouldPassFilters(include, exclude filter.Filter, key string) bool + func ShouldTagsPass(passFilters, dropFilters []TagFilter, tags []*telegraf.Tag) bool + type AggregatorConfig struct + Alias string + Delay time.Duration + DropOriginal bool + Filter Filter + Grace time.Duration + ID string + LogLevel string + MeasurementPrefix string + MeasurementSuffix string + Name string + NameOverride string + Period time.Duration + Source string + Tags map[string]string + type Buffer interface + Add func(metrics ...telegraf.Metric) int + BeginTransaction func(batchSize int) *Transaction + Close func() error + EndTransaction func(*Transaction) + Len func() int + Stats func() BufferStats + func NewBuffer(name, id, alias string, capacity int, strategy, path string) (Buffer, error) + type BufferStats struct + BufferLimit selfstat.Stat + BufferSize selfstat.Stat + MetricsAdded selfstat.Stat + MetricsDropped selfstat.Stat + MetricsRejected selfstat.Stat + MetricsWritten selfstat.Stat + func NewBufferStats(tags map[string]string, capacity int) BufferStats + type DiskBuffer struct + func NewDiskBuffer(id, path string, stats BufferStats) (*DiskBuffer, error) + func (b *DiskBuffer) Add(metrics ...telegraf.Metric) int + func (b *DiskBuffer) BeginTransaction(batchSize int) *Transaction + func (b *DiskBuffer) Close() error + func (b *DiskBuffer) EndTransaction(tx *Transaction) + func (b *DiskBuffer) Len() int + func (b *DiskBuffer) Stats() BufferStats + type Filter struct + FieldExclude []string + FieldInclude []string + MetricPass string + NameDrop []string + NameDropSeparators string + NamePass []string + NamePassSeparators string + TagDropFilters []TagFilter + TagExclude []string + TagInclude []string + TagPassFilters []TagFilter + func (f *Filter) Compile() error + func (f *Filter) IsActive() bool + func (f *Filter) Modify(metric telegraf.Metric) + func (f *Filter) Select(metric telegraf.Metric) (bool, error) + type InputConfig struct + Alias string + AlwaysIncludeGlobalTags bool + AlwaysIncludeLocalTags bool + CollectionJitter time.Duration + CollectionOffset time.Duration + Filter Filter + ID string + Interval time.Duration + LogLevel string + MeasurementPrefix string + MeasurementSuffix string + Name string + NameOverride string + Precision time.Duration + Source string + StartupErrorBehavior string + Tags map[string]string + TimeSource string + type MemoryBuffer struct + func NewMemoryBuffer(capacity int, stats BufferStats) (*MemoryBuffer, error) + func (*MemoryBuffer) Close() error + func (b *MemoryBuffer) Add(metrics ...telegraf.Metric) int + func (b *MemoryBuffer) BeginTransaction(batchSize int) *Transaction + func (b *MemoryBuffer) EndTransaction(tx *Transaction) + func (b *MemoryBuffer) Len() int + func (b *MemoryBuffer) Stats() BufferStats + type OutputConfig struct + Alias string + BufferDirectory string + BufferStrategy string + Filter Filter + FlushInterval time.Duration + FlushJitter time.Duration + ID string + LogLevel string + MetricBatchSize int + MetricBufferLimit int + Name string + NameOverride string + NamePrefix string + NameSuffix string + Source string + StartupErrorBehavior string + type ParserConfig struct + Alias string + DataFormat string + DefaultTags map[string]string + LogLevel string + Parent string + type ProcessorConfig struct + Alias string + Filter Filter + ID string + LogLevel string + Name string + Order int64 + Source string + 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) ID() string + func (r *RunningAggregator) Init() error + func (r *RunningAggregator) Log() telegraf.Logger + func (r *RunningAggregator) LogName() string + func (r *RunningAggregator) MakeMetric(telegrafMetric 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 struct + Config *InputConfig + GatherTime selfstat.Stat + GatherTimeouts selfstat.Stat + Input telegraf.Input + MetricsGathered selfstat.Stat + StartupErrors selfstat.Stat + func NewRunningInput(input telegraf.Input, config *InputConfig) *RunningInput + func (r *RunningInput) Gather(acc telegraf.Accumulator) error + func (r *RunningInput) ID() string + func (r *RunningInput) IncrGatherTimeouts() + 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) Probe() error + func (r *RunningInput) SetDefaultTags(tags map[string]string) + func (r *RunningInput) Start(acc telegraf.Accumulator) error + func (r *RunningInput) Stop() + type RunningOutput struct + BatchReady chan time.Time + Config *OutputConfig + MetricBatchSize int + MetricBufferLimit int + MetricsFiltered selfstat.Stat + Output telegraf.Output + StartupErrors selfstat.Stat + WriteTime selfstat.Stat + func NewRunningOutput(output telegraf.Output, config *OutputConfig, batchSize, bufferLimit int) *RunningOutput + func (r *RunningOutput) AddMetric(metric telegraf.Metric) + func (r *RunningOutput) AddMetricNoCopy(metric telegraf.Metric) + func (r *RunningOutput) BufferLength() int + func (r *RunningOutput) Close() + func (r *RunningOutput) Connect() error + func (r *RunningOutput) ID() string + func (r *RunningOutput) Init() error + func (r *RunningOutput) Log() telegraf.Logger + func (r *RunningOutput) LogBufferStatus() + func (r *RunningOutput) LogName() string + func (r *RunningOutput) Write() error + func (r *RunningOutput) WriteBatch() error + type RunningParser struct + Config *ParserConfig + MetricsParsed selfstat.Stat + ParseTime selfstat.Stat + Parser telegraf.Parser + func NewRunningParser(parser telegraf.Parser, config *ParserConfig) *RunningParser + func (r *RunningParser) Init() error + func (r *RunningParser) Log() telegraf.Logger + func (r *RunningParser) LogName() string + func (r *RunningParser) Parse(buf []byte) ([]telegraf.Metric, error) + func (r *RunningParser) ParseLine(line string) (telegraf.Metric, error) + func (r *RunningParser) SetDefaultTags(tags map[string]string) + type RunningProcessor struct + Config *ProcessorConfig + Processor telegraf.StreamingProcessor + func NewRunningProcessor(processor telegraf.StreamingProcessor, config *ProcessorConfig) *RunningProcessor + func (*RunningProcessor) MakeMetric(metric telegraf.Metric) telegraf.Metric + func (rp *RunningProcessor) Add(m telegraf.Metric, acc telegraf.Accumulator) error + func (rp *RunningProcessor) ID() string + func (rp *RunningProcessor) Init() error + func (rp *RunningProcessor) Log() telegraf.Logger + func (rp *RunningProcessor) LogName() string + func (rp *RunningProcessor) Start(acc telegraf.Accumulator) error + func (rp *RunningProcessor) Stop() + type RunningProcessors []*RunningProcessor + func (rp RunningProcessors) Len() int + func (rp RunningProcessors) Less(i, j int) bool + func (rp RunningProcessors) Swap(i, j int) + type RunningSerializer struct + BytesSerialized selfstat.Stat + Config *SerializerConfig + MetricsSerialized selfstat.Stat + SerializationTime selfstat.Stat + Serializer telegraf.Serializer + func NewRunningSerializer(serializer telegraf.Serializer, config *SerializerConfig) *RunningSerializer + func (r *RunningSerializer) Init() error + func (r *RunningSerializer) Log() telegraf.Logger + func (r *RunningSerializer) LogName() string + func (r *RunningSerializer) Serialize(metric telegraf.Metric) ([]byte, error) + func (r *RunningSerializer) SerializeBatch(metrics []telegraf.Metric) ([]byte, error) + type SerializerConfig struct + Alias string + DataFormat string + DefaultTags map[string]string + LogLevel string + Parent string + type TagFilter struct + Name string + Values []string + func (tf *TagFilter) Compile() error + type Transaction struct + Accept []int + Batch []telegraf.Metric + Reject []int + func (*Transaction) KeepAll() + func (tx *Transaction) AcceptAll() + func (tx *Transaction) InferKeep() []int
Go to main page