dq

package

v0.0.0-...-8cdaf41 Latest Latest Go to latest Published: Sep 5, 2018 License: MIT Imports: 13 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/TeamFat/DelayQueue

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Init ¶

func Init()

Init 延时队列初始化

func Pop ¶

func Pop(c *gin.Context)

Pop 出队

func Push ¶

func Push(c *gin.Context)

Push 入队

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时间戳
	Body  string `json:"body" msgpack:"4"`
}

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL