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.

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.