Package manager creates and manages multiple streams, providing an API for performing CRUD operations.

New creates a new stream.Type.

NewConfig returns a new configuration with default values.

OptAddInputPipelines adds additional pipelines that will be constructed for each input of the Benthos stream.

OptAddOutputPipelines adds additional pipelines that will be constructed for each output of the Benthos stream.

OptAddProcessors adds additional processors that will be constructed for each logical thread of the processing pipeline layer of the Benthos stream.

OptOnClose sets a closure to be called when the stream closes.

OptSetLogger sets the logging output to be used by all components of the stream.

OptSetLogSimple sets the logging output to a simpler log interface (implemented by the standard *log.Logger.).

OptSetManager sets the service manager to be used by all components of the stream.

OptSetStats sets the metrics aggregator to be used by all components of the stream.

Config is a configuration struct representing all four layers of a Benthos stream.

Type creates and manages the lifetime of a Benthos stream.