processors

Documentation

Index

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

Functions

func AppendFromConfig

func AppendFromConfig(conf input.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 input configuration will also be initialized.

func WrapConstructor

func WrapConstructor(fn func(input.Config, bundle.NewManagement) (input.Streamed, error)) bundle.InputConstructor

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