go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-22 00:30:17 +08:00
Code Issues Projects Releases Wiki Activity

Debug commit

Browse Source
This commit is contained in:
Ken Hibino 2020-06-06 21:16:44 -07:00
parent d9161d621f
commit 6b8a4eed54
3 changed files with 27 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
asynq.go
View File

@ -183,6 +183,7 @@ func createRedisClient(r RedisConnOpt) *redis.Client {
DB: r.DB, DB: r.DB,
PoolSize: r.PoolSize, PoolSize: r.PoolSize,
TLSConfig: r.TLSConfig, TLSConfig: r.TLSConfig,
MaxRetries: 10,
}) })
case RedisClientOpt: case RedisClientOpt:
return redis.NewClient(&redis.Options{ return redis.NewClient(&redis.Options{
@ -192,6 +193,7 @@ func createRedisClient(r RedisConnOpt) *redis.Client {
DB: r.DB, DB: r.DB,
PoolSize: r.PoolSize, PoolSize: r.PoolSize,
TLSConfig: r.TLSConfig, TLSConfig: r.TLSConfig,
MaxRetries: 10,
}) })
case *RedisFailoverClientOpt: case *RedisFailoverClientOpt:
return redis.NewFailoverClient(&redis.FailoverOptions{ return redis.NewFailoverClient(&redis.FailoverOptions{

13
heartbeat.go
View File

@ -165,14 +165,23 @@ func (h *heartbeater) beat() {
} }
// Debug purpose // Debug purpose
rdb, ok := h.broker.(*rdb.RDB) r, ok := h.broker.(*rdb.RDB)
if !ok { if !ok {
return return
} }
stats, err := rdb.CurrentStats() stats, err := r.CurrentStats()
if err != nil { if err != nil {
h.logger.Errorf("could not get current stat: %v", err) h.logger.Errorf("could not get current stat: %v", err)
} else { } else {
h.logger.Debugf("current stats: %+v", stats) h.logger.Debugf("current stats: %+v", stats)
} }
inProgress, err := r.ListInProgress(rdb.Pagination{Size: 10})
if err != nil {
h.logger.Errorf("could not get in-progress tasks: %v", err)
} else {
for _, t := range inProgress {
h.logger.Debugf("in-progress tasks: %+v", t)
}
}
} }

2
syncer.go
View File

@ -71,8 +71,10 @@ func (s *syncer) start(wg *sync.WaitGroup) {
requests = append(requests, req) requests = append(requests, req)
case <-time.After(s.interval): case <-time.After(s.interval):
var temp []*syncRequest var temp []*syncRequest
s.logger.Infof("sync requests length: %d", len(requests))
for _, req := range requests { for _, req := range requests {
if err := req.fn(); err != nil { if err := req.fn(); err != nil {
s.logger.Errorf("could not sync: %v: %v", req.errMsg, err)
temp = append(temp, req) temp = append(temp, req)
} }
} }