processors

Documentation

Index

• func AppendFromConfig(conf output.Config, mgr bundle.NewManagement, ...) []processor.PipelineConstructorFunc
• func WrapConstructor(fn func(output.Config, bundle.NewManagement) (output.Streamed, error)) bundle.OutputConstructor

Functions

func AppendFromConfig

func AppendFromConfig(conf output.Config, mgr bundle.NewManagement, pipelines ...processor.PipelineConstructorFunc) []processor.PipelineConstructorFunc

AppendFromConfig takes a variant arg of pipeline constructor functions and returns a new slice of them where the processors of the provided output configuration will also be initialized.

func WrapConstructor

func WrapConstructor(fn func(output.Config, bundle.NewManagement) (output.Streamed, error)) bundle.OutputConstructor

WrapConstructor provides a way to define an output constructor without manually initializing processors of the config.