api_worker

Sep 14, 2020

Changes in this version

+ var CountTask = taskq.RegisterTask(&taskq.TaskOptions{ ... })

+ var MainQueue = QueueFactory.RegisterQueue(&taskq.QueueOptions{ ... })

+ var QueueFactory = redisq.NewFactory()

+ var Redis = redis.NewClient(&redis.Options{ ... })

+ func GetLocalCounter() int32

+ func IncrLocalCounter()

+ func LogStats()

+ func WaitSignal() os.Signal