Package parallel contains implementations of various buffer types where the buffer can be consumed by any number of parallel consumer threads.

Package single contains implementations of various buffer types where the buffer can only be consumed by a single thread (but any number of writers).

Descriptions returns a formatted string of collated descriptions of each type.

New creates a buffer type based on a buffer configuration.

NewConfig returns a configuration struct fully populated with default values.

NewEmpty creates a new buffer interface but doesn't buffer messages.

NewMemory - Create a buffer held in memory.

NewMmapFile creates a buffer held in memory and persisted to file through memory map.

NewParallelWrapper creates a new Producer/Consumer around a buffer.

NewSingleWrapper creates a new Producer/Consumer around a buffer.

SanitiseConfig returns a sanitised version of the Config, meaning sections that aren't relevant to behaviour are removed.

String constants representing each buffer type.

String constants representing each buffer type.

String constants representing each buffer type.

Constructors is a map of all buffer types with their specs.

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

Empty is an empty buffer, simply forwards messages on directly.

ParallelWrapper wraps a buffer with a Producer/Consumer interface.

SingleWrapper wraps a buffer with a Producer/Consumer interface.

TypeSpec is a constructor and usage description for each buffer type.

Parallel represents a method of buffering messages such that they can be consumed by any number of parallel consumers, and can be acknowledged in any order.

Single represents a method of buffering sequential messages, supporting only a single, sequential consumer.

Type is an interface implemented by all buffer types.