tasklist

Documentation

Index

• Constants
• type TaskList
  • func New(ctx context.Context) *TaskList
  • func (l *TaskList) Ignore(t interface{})
  • func (l *TaskList) Pop() (task interface{}, done func(error), err error)
  • func (l *TaskList) Put(t interface{}) (status, error)
  • func (l *TaskList) Wait()

Constants

const (
	StatusIgnored status = iota
	StatusPending
	StatusProcessing
	StatusErrored
	StatusFinished
)

const (
	ErrDone = errors.Error("all tasks done")
)

Types

type TaskList

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

func New

func New(ctx context.Context) *TaskList

func (*TaskList) Ignore

func (l *TaskList) Ignore(t interface{})

func (*TaskList) Pop

func (l *TaskList) Pop() (task interface{}, done func(error), err error)

func (*TaskList) Put

func (l *TaskList) Put(t interface{}) (status, error)

func (*TaskList) Wait

func (l *TaskList) Wait()