NewConfig returns a configuration struct fully populated with default values.

NewStream creates a new Producer/Consumer around a buffer.

Config is the all encompassing configuration struct for all buffer types.

Stream wraps a read/write buffer implementation with a channel based streaming component that satisfies the internal Bento Consumer and Producer interfaces.

ReaderWriter is a read/write interface implemented by buffers.

Streamed is an interface implemented by all buffer types that provides stream based methods.

AckFunc is a function used to acknowledge receipt of a message batch from a buffer.