delayqueue

Documentation

Index

• Variables
• func Init()
• func Push(job Job) error
• func Remove(jobId string) error
• type BucketItem
• type Job
  • func Get(jobId string) (*Job, error)
  • func Pop(topics []string) (*Job, error)

Variables

var (
	// RedisPool RedisPool连接池实例
	RedisPool *redis.Pool
)

Functions

func Init

func Init()

Init 初始化延时队列

func Push

func Push(job Job) error

Push 添加一个Job到队列中

func Remove

func Remove(jobId string) error

Remove 删除Job

Types

type BucketItem

type BucketItem struct {
	// contains filtered or unexported fields
}

BucketItem bucket中的元素

type Job

type Job struct {
	Topic string `json:"topic" msgpack:"1"`
	Id    string `json:"id" msgpack:"2"`    // job唯一标识ID
	Delay int64  `json:"delay" msgpack:"3"` // 延迟时间, unix时间戳
	TTR   int64  `json:"ttr" msgpack:"4"`
	Body  string `json:"body" msgpack:"5"`
}

Job 使用msgpack序列化后保存到Redis,减少内存占用

func Get

func Get(jobId string) (*Job, error)

Get 查询Job

func Pop

func Pop(topics []string) (*Job, error)

Pop 轮询获取Job