Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.