Versions in this module Expand all Collapse all v1 v1.7.0 Feb 14, 2023 Changes in this version + type TaskQueue struct + func NewTaskQueue(syncFn func(string, interface{}) error) *TaskQueue + func (tq *TaskQueue) Enqueue(name string, data interface{}) + func (tq *TaskQueue) Len() int + func (tq *TaskQueue) Requeue(task task, err error) + func (tq *TaskQueue) RequeueAfter(t task, err error, after time.Duration) + func (tq *TaskQueue) Run(period time.Duration, stopCh <-chan struct{}) + func (tq *TaskQueue) Shutdown()
Go to main page