delayjob

Documentation

Index

• Variables
• func Init()
• func Push(value interface{}) error
• type BaseOrm
  • func (that *BaseOrm) InitDB()
• type BucketItem
• type CloseOrder
• type CloseOrderBody
• type Jobs

Variables

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

Functions

func Init

func Init()

Init 初始化延时队列

func Push

func Push(value interface{}) error

Push 添加一个Job到队列中

Types

type BaseOrm

type BaseOrm struct {
	DB *gorm.DB
}

func (*BaseOrm) InitDB

func (that *BaseOrm) InitDB()

* 初始化数据库

type BucketItem

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

BucketItem bucket中的元素

type CloseOrder

type CloseOrder struct {
	Jobs
	Body CloseOrderBody `json:"body"`
}

* 关闭vip订单

type CloseOrderBody

type CloseOrderBody struct {
	OrderId string `json:"order_id"`
}

* 关闭vip订单具体操作

type Jobs

type Jobs struct {
	Topic string `json:"topic"`
	ID    string `json:"id"`    //job唯一标识ID
	Delay int64  `json:"delay"` //延迟时间, unix时间戳
	TTR   int64  `json:"ttr"`
}

* Job体