Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline.

Package queuetest provides common functionality tests all queue implementations must pass.

FindFactory retrieves a queue types constructor.

RegisterQueueType registers a new queue type.

Namespace is the feature namespace for queue definition.

BufferConfig returns the pipelines buffering settings, for the pipeline to use.

ProducerConfig as used by the Pipeline to configure some custom callbacks between pipeline and queue.

ACKListener listens to special events to be send by queue implementations.

Batch of events to be returned to Consumers.

Consumer is an interface to be used by the pipeline output workers, used to read events from the head of the queue.

Producer is an interface to be used by the pipelines client to forward events to a queue.

Queue is responsible for accepting, forwarding and ACKing events.

Factory for creating a queue used by a pipeline instance.