processors

Documentation

Index

• Variables
• func Add(name string, creator Creator)
• func AddStreaming(name string, creator StreamingCreator)
• func NewStreamingProcessorFromProcessor(p telegraf.Processor) telegraf.StreamingProcessor
• type Creator
• type HasUnwrap
• type StreamingCreator

Variables

var Deprecations = map[string]telegraf.DeprecationInfo{}

Deprecations lists the deprecated plugins

var Processors = map[string]StreamingCreator{}

all processors are streaming processors. telegraf.Processor processors are upgraded to telegraf.StreamingProcessor

Functions

func Add

func Add(name string, creator Creator)

Add adds a telegraf.Processor processor

func AddStreaming

func AddStreaming(name string, creator StreamingCreator)

AddStreaming adds a telegraf.StreamingProcessor streaming processor

func NewStreamingProcessorFromProcessor

func NewStreamingProcessorFromProcessor(p telegraf.Processor) telegraf.StreamingProcessor

NewStreamingProcessorFromProcessor is a converter that turns a standard processor into a streaming processor

Types

type Creator

type Creator func() telegraf.Processor

type HasUnwrap

type HasUnwrap interface {
	Unwrap() telegraf.Processor
}

HasUnwrap indicates the presence of an Unwrap() function to retrieve the underlying telegraf.Processor.

type StreamingCreator

type StreamingCreator func() telegraf.StreamingProcessor