uniqueue

Documentation

Index

• Variables
• type TaskQueue
• type TaskResult

Variables

var (
	// ErrNotYetImplemented refers to the not yet implemented error
	ErrNotYetImplemented = errors.New("not yet implemented")
)

Types

type TaskQueue

type TaskQueue interface {
	StartWorker() error
	Register(taskName string, task interface{}) error
	SubmitTask(task string, args ...interface{}) (TaskResult, error)
	SubmitTaskWithMapArgs(task string, args map[string]interface{}) (TaskResult, error)
	Close() error
}

TaskQueue represents an abstraction of a task queue

type TaskResult

type TaskResult interface {
}

TaskResult represents an abtraction of task result