Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQueue ¶
func NewQueue(conf QueueConfig) (monsterqueue.Queue, error)
Creates a new queue. The QueueConfig parameter will tell us how to connect to mongodb. This command will fail if the MongoDB server is not available.
Tasks registered in this queue instance will run when `ProcessLoop` is called in this *same* instance.
Types ¶
Click to show internal directories.
Click to hide internal directories.