delayqueue

package module

v0.0.0-...-4f72b75 Latest Latest Go to latest Published: Oct 15, 2020 License: MIT Imports: 5 Imported by: 0

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/dcb9/delayqueue

README ¶

Delay queue

How to use

TODO

Add logs
Run as a service
Translate all docs and comments to English

Acknowledgment

Documentation ¶

Index ¶

func NewRedisPool(maxIdle int, network, address, password string) *redis.Pool
type DelayQueue
- func NewDelayQueue(redisPool *redis.Pool) *DelayQueue
- func NewDelayQueueWithPrefix(redisPool *redis.Pool, keyPrefix string) *DelayQueue
type Job

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewRedisPool ¶

func NewRedisPool(maxIdle int, network, address, password string) *redis.Pool

Types ¶

type DelayQueue ¶

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

func NewDelayQueue ¶

func NewDelayQueue(redisPool *redis.Pool) *DelayQueue

func NewDelayQueueWithPrefix ¶

func NewDelayQueueWithPrefix(redisPool *redis.Pool, keyPrefix string) *DelayQueue

func (*DelayQueue) DeQueue ¶

func (q *DelayQueue) DeQueue(topics []string) (*Job, error)

获取任务任务执行完成后需要调用 Remove 将任务删除

func (*DelayQueue) EnQueue ¶

func (q *DelayQueue) EnQueue(job *Job) error

func (*DelayQueue) Remove ¶

func (q *DelayQueue) Remove(jobId string) error

func (*DelayQueue) Run ¶

func (q *DelayQueue) Run() error

Run transits ready job to ready queue from delay bucket It's a thread safe method, you can run as many as you'd like to

type Job ¶

type Job struct {
	Topic string `json:"topic"`
	ID    string `json:"id"`    // job唯一标识ID
	Delay int64  `json:"delay"` // 延迟时间, unix时间戳
	TTR   int64  `json:"ttr"`   // time-to-run Job执行超时时间。单位：秒。
	Body  []byte `json:"body"`
}

Source Files ¶

View all Source files

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