Documentation
¶
Index ¶
- Constants
- type Queue
- 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)
Constants ¶
View Source
const DefaultDefaultMaxAttempts = 3
DefaultDefaultMaxAttempts 队列是默认的默认尝试次数
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue 是一个使用 SQLite 实现的队列
func (*Queue) BatchRefreshStatuses ¶
func (q *Queue) BatchRefreshStatuses(appliedStatuses taskqueue.TaskStatusSet, appliedTaskTypes []string, filter taskqueue.Refresher) (err error)
BatchRefreshStatuses 批量刷新任务的状态
func (*Queue) DequeueForProcess ¶
DequeueForProcess 取出一个等待队列中处于等待状态的任务, 并将其标记为处理中状态
func (*Queue) EnqueueWithOptions ¶
func (q *Queue) EnqueueWithOptions(taskType string, taskData []byte, opts taskqueue.EnqueueOptions) (id int, err error)
EnqueueWithOptions 将任务根据 opts 的设置放入队列
func (*Queue) GetDefaultMaxAttempts ¶
GetDefaultMaxAttempts 获取默认的最大尝试次数
func (*Queue) ReportProcessResult ¶
func (q *Queue) ReportProcessResult(id int, result taskqueue.ProcessResult) (err error)
ReportProcessResult 是在完成处理取出的任务后, 向队列报告结果的方法
func (*Queue) SetDefaultMaxAttempts ¶
SetDefaultMaxAttempts 设置项目放入队列时, 默认的最大尝试次数
Source Files
Click to show internal directories.
Click to hide internal directories.