taskq

README

TaskQ

Goroutine manager.

---

Documentation

Index

• Variables
• type RetryableTask
  • func (t *RetryableTask) Do(ctx context.Context) error
• type Status
  • func TaskStatus(task Task) Status
• type Task
  • func NewRetryableTask(task Task, maxRetries int) Task
• type TaskFunc
  • func (t TaskFunc) Do(ctx context.Context) error
• type TaskManager
  • func NewTaskManger(taskQ *TaskQ) *TaskManager
  • func (m *TaskManager) Close() error
  • func (m *TaskManager) Enqueue(task Task) int64
  • func (m *TaskManager) Start() error
  • func (m *TaskManager) Task(id int64) Task
• type TaskQ
  • func New(size int) *TaskQ
  • func (t *TaskQ) Close() error
  • func (t *TaskQ) Enqueue(task Task) int64
  • func (t *TaskQ) Start() error

Variables

var ErrRetryTask = errors.New("error occurred during task execution. retry task")

Types

type RetryableTask

type RetryableTask struct {
	// contains filtered or unexported fields
}

func (*RetryableTask) Do

func (t *RetryableTask) Do(ctx context.Context) error

type Status

type Status byte

const (
	None Status = iota
	Pending
	InProgress
	Done
	Failed
)

func TaskStatus

func TaskStatus(task Task) Status

type Task

type Task interface {
	Do(ctx context.Context) error
}

Task for TaskQ

func NewRetryableTask

func NewRetryableTask(task Task, maxRetries int) Task

type TaskFunc

type TaskFunc func(ctx context.Context) error

func (TaskFunc) Do

func (t TaskFunc) Do(ctx context.Context) error

type TaskManager

type TaskManager struct {
	// contains filtered or unexported fields
}

func NewTaskManger

func NewTaskManger(taskQ *TaskQ) *TaskManager

func (*TaskManager) Close

func (m *TaskManager) Close() error

func (*TaskManager) Enqueue

func (m *TaskManager) Enqueue(task Task) int64

func (*TaskManager) Start

func (m *TaskManager) Start() error

func (*TaskManager) Task

func (m *TaskManager) Task(id int64) Task

type TaskQ

type TaskQ struct {
	TaskDone   func(int64, Task)
	TaskFailed func(int64, Task, error)
	// contains filtered or unexported fields
}

func New

func New(size int) *TaskQ

func (*TaskQ) Close

func (t *TaskQ) Close() error

func (*TaskQ) Enqueue

func (t *TaskQ) Enqueue(task Task) int64

func (*TaskQ) Start

func (t *TaskQ) Start() error