NewBoltDB creates a memory based parallel buffer.

NewBoltDBConfig returns a BoltDBConfig with default parameters.

NewMemory creates a memory based parallel buffer.

Static keys holding BoltDB bucket names for the Benthos buffer.

BoltDB is a parallel buffer implementation that allows multiple parallel consumers to read and purge messages from a BoltDB database asynchronously.

BoltDBConfig contains configuration params for the BoltDB buffer type.

Memory is a parallel buffer implementation that allows multiple parallel consumers to read and purge messages from the buffer asynchronously.

AckFunc is a func returned when a message is read from a parallel buffer.