package
Version:
v0.1.6
Opens a new window with list of versions in this module.
Published: Nov 16, 2023
License: MIT
Opens a new window with license information.
Imports: 6
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
DefaultDeadlineFunc
@Description: 默认消息超时未确认处理,将超时任务重新退回队列
@return func(queue *Queue, id string, data interface{}, deadline time.Time)
type Queue struct {
DeadlineFunc func(queue *Queue, id string, data interface{}, deadline time.Time)
}
NewQueue
@Description: 创建消息队列
@return *Queue
Done
@Description: 消息确认
@receiver q
@param id
Get
@Description: 接收
@receiver q
@param deadline 消息确认超时,设置非nil后需要使用Done()进行消息确认
@param block 阻塞
@return id 队列id
@return data 内容
@return ok 是否获取到
func (q *Queue) Put(data interface{})
Put
@Description: 推入队列
@receiver q
@param data
Source Files
¶
Click to show internal directories.
Click to hide internal directories.