Versions in this module Expand all Collapse all v0 v0.1.0 Nov 5, 2018 Changes in this version + const DefaultDefaultMaxAttempts + type Queue struct + func Open(path string) (q *Queue, err error) + func OpenInMemory() (q *Queue, err error) + func (q *Queue) BatchRefreshStatuses(appliedStatuses taskqueue.TaskStatusSet, appliedTaskTypes []string, ...) (err error) + func (q *Queue) Close() (err error) + func (q *Queue) DequeueForProcess() (id int, taskType string, taskData []byte, err error) + func (q *Queue) EnqueueWithOptions(taskType string, taskData []byte, opts taskqueue.EnqueueOptions) (id int, err error) + func (q *Queue) GetDefaultMaxAttempts() (i int) + func (q *Queue) ReportProcessResult(id int, result taskqueue.ProcessResult) (err error) + func (q *Queue) SetDefaultMaxAttempts(i int)