Versions in this module Expand all Collapse all v1 v1.0.2 Oct 3, 2023 v1.0.1 Oct 3, 2023 Changes in this version + var InactiveError = fmt.Errorf("inactive task queue") + type TaskQueue struct + func NewTaskQueue(name string) TaskQueue + func (q *TaskQueue) Active() bool + func (q *TaskQueue) Enqueue(fn func() error) chan error + func (q *TaskQueue) Run(fn func() error) error + func (q *TaskQueue) Start(depth int) error + func (q *TaskQueue) Stop(cause error) error + func (q *TaskQueue) StopNoWait(cause error) error
Go to main page