MCPcopy
hub / github.com/influxdata/telegraf / Processor

Interface Processor

processor.go:6–11  ·  view source on GitHub ↗

Processor is a processor plugin interface for defining new inline processors. these are extremely efficient and should be used over StreamingProcessor if you do not need asynchronous metric writes.

Source from the content-addressed store, hash-verified

4// these are extremely efficient and should be used over StreamingProcessor if
5// you do not need asynchronous metric writes.
6type Processor interface {
7 PluginDescriber
8
9 // Apply the filter to the given metric.
10 Apply(in ...Metric) []Metric
11}
12
13// StreamingProcessor is a processor that can take in a stream of messages
14type StreamingProcessor interface {

Callers 14

ApplyMethod · 0.65
TestTemplateApplyFunction · 0.65
ParseLineMethod · 0.65
ApplyTemplateMethod · 0.65
readDWMetricsMethod · 0.65
AddMethod · 0.65
TestFieldConversionsFunction · 0.65
TestFieldKeyConversionsFunction · 0.65
TestInitFunction · 0.95
InitMethod · 0.95
InitMethod · 0.95

Implementers 15

Engineinternal/templating/engine.go
Templateinternal/templating/template.go
testConfigProcessorplugins/common/shim/config_test.go
testProcessorplugins/common/shim/processor_test.go
Stringsplugins/processors/strings/strings.go
Scaleplugins/processors/scale/scale.go
Dedupplugins/processors/dedup/dedup.go
Defaultsplugins/processors/defaults/defaults.g
Processorplugins/processors/lookup/lookup.go
Unpivotplugins/processors/unpivot/unpivot.go
Printerplugins/processors/printer/printer.go
TagLimitplugins/processors/tag_limit/tag_limit

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…