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.

Feature creates a new type of queue.

FindFactory retrieves a queue types constructor.

RegisterType 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.

Batch of events to be returned to Consumers.

Consumer interface to be used by the pipeline output workers.

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

Producer interface to be used by the pipelines client to forward events to be published to the queue.

Queue is responsible for accepting, forwarding and ACKing events.

Factory for creating a queue used by a pipeline instance.