# README
go-queue
Go queue provides a unified API across a variety of different queue backend like Redis, in-memory sync/async and RabbitMQ.
Features
- RabbitMQ, in-memory sync/async backends.
- Multiple message codecs (json, gob and msgpack) supported by go-encoding, you can also implement your own codecs.
- Automatic message encoding and compression.
- Support publishing raw messages for easy use with other languages.
- Support for asynchronous task management and distribution.
Install
go get -u github.com/ibllex/go-queue
Qucik Usage
For basic asynchronous message useage please see the example/raw
For asynchronous task useage please see the example/task
License
This library is under the BSD-2 license.
# Functions
Add add a queue connector.
Default returns the queue for default name.
No description provided by the author
Dispatch an message to queue.
No description provided by the author
No description provided by the author
Get returns the queue for given name.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
SetDefault set the name of the default queue.
No description provided by the author
Distribute all tasks.
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
Consumer state.
Consumer state.
# Variables
No description provided by the author
# Structs
consumer reserves messages from the queue, processes them, and then either releases or deletes messages from the queue.
No description provided by the author
No description provided by the author
Task registration management
.