Package chanqueue provides a local queue based on channels.

Discard returns a [MessageProcessor] that discards all the received messages.

ErrMaxTimeNoRead is returned by a queue reader when there were no messages available in the queue for more than the configured amount of time.

Message defines the information a queue reader passes to a processor about a message.

MessageProcessor defines the methods needed by a queue reader implementation to process the messages it reads.

Reader defines the methods that all the queue reader implementations must fulfill.

Writer defines the functions that a queue writer must implement.