workqueue

Feb 2, 2019

Changes in this version

+ func NewTaskQueue(namespace string, redisPool *redis.Pool, v interface{}, numWorkers uint) uniqueue.TaskQueue

+ type Config struct

+ Namespace string

+ NumWorkers uint

+ RedisURL string

+ type TaskQueue struct

+ func (queue *TaskQueue) Close() error

+ func (queue *TaskQueue) Register(taskName string, task interface{}) error

+ func (queue *TaskQueue) StartWorker() error

+ func (queue *TaskQueue) SubmitTask(task string, args ...interface{}) (uniqueue.TaskResult, error)

+ func (queue *TaskQueue) SubmitTaskWithMapArgs(task string, args map[string]interface{}) (uniqueue.TaskResult, error)

+ type TaskResult struct

+ func (taskResult *TaskResult) FromJob(job *work.Job) error