Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RemoveCsvBoom ¶
Types ¶
type RedisQueueDelay ¶
type RedisQueueDelay struct {
// contains filtered or unexported fields
}
func NewRedisQueueDelay ¶
func NewRedisQueueDelay(client *redis.Client, interval, number uint64) *RedisQueueDelay
NewRedisQueueDelay 创建一个新的队列 client redis连接, interval 消费端间隔,单位毫秒, number 每次消费数目,结果小于等于此数字
Click to show internal directories.
Click to hide internal directories.