Documentation ¶
Index ¶
- func NewTaskQueue(namespace string, redisPool *redis.Pool, v interface{}, numWorkers uint) uniqueue.TaskQueue
- type Config
- type TaskQueue
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type TaskQueue ¶
type TaskQueue struct {
// contains filtered or unexported fields
}
TaskQueue represents a new task queue implementing gocraft/work
func (*TaskQueue) StartWorker ¶
func (*TaskQueue) SubmitTask ¶
func (queue *TaskQueue) SubmitTask(task string, args ...interface{}) (uniqueue.TaskResult, error)
SubmitTask submits a givne task to the queue
func (*TaskQueue) SubmitTaskWithMapArgs ¶
func (queue *TaskQueue) SubmitTaskWithMapArgs(task string, args map[string]interface{}) (uniqueue.TaskResult, error)
SubmitTaskWithMapArgs submits a given task to the queue with the args as a map
Click to show internal directories.
Click to hide internal directories.