Versions in this module Expand all Collapse all v0 v0.0.2 Nov 9, 2021 Changes in this version + const RetryInterval + const RetryNum + func InitClient(opt *redis.Options) + func InitClusterClient(opt *redis.ClusterOptions) + func RetryEnqueue(queue string, member interface{}) (string, error) type EnqueueData + RetryInterval int64 + RetryNum uint64 v0.0.1 Nov 3, 2021 Changes in this version + const DefaultCount + const DefaultSleep + const MaxCount + var Config *config + func Configure(options map[string]string) + func Enqueue(queue string, message interface{}, delayTime time.Duration) (string, error) + func GetGoroutineID() uint64 + func Process(queue string, delayFunc delayFunc, concurrency int, params ...Params) + func Run() + func Stats(w http.ResponseWriter, req *http.Request) + func StatsServer(port int) + type EnqueueData struct + Message interface{} + MsgId string + type Params struct + PollSize int64