goworkerqueue

Documentation

Index

• func NewTaskQueue() uniqueue.TaskQueue
• 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)

Functions

func NewTaskQueue

func NewTaskQueue() uniqueue.TaskQueue

NewTaskQueue returns a task queue implementing benmanns/goworker

Types

type TaskQueue

type TaskQueue struct {
}

TaskQueue represents a new task queue based on benmanns/goworker

func (*TaskQueue) Close

func (queue *TaskQueue) Close() error

func (*TaskQueue) Register

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

func (*TaskQueue) StartWorker

func (queue *TaskQueue) StartWorker() error

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