delayed_queue

README

delayed_queue

用redis做一个延时队列

Documentation

Index

• func Dequeue(ctx context.Context, client *redis.Client, queueID string, limit int64) ([]string, error)
• func Enqueue(ctx context.Context, client *redis.Client, queueID string, msg string, ...) error

Functions

func Dequeue

func Dequeue(ctx context.Context, client *redis.Client, queueID string, limit int64) ([]string, error)

拉取已经到期的消息

func Enqueue

func Enqueue(ctx context.Context, client *redis.Client, queueID string, msg string, delayedMs int64) error

将一条消息msg放入到延时队列中，该消息的延时时间为delayedMs