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 StreamingCreator

Variables

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 StreamingCreator

type StreamingCreator func() telegraf.StreamingProcessor