go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-10-03 05:12:01 +08:00
Code Issues Projects Releases Wiki Activity

Add workers command to asynqmon

Browse Source
This commit is contained in:
Ken Hibino
2020-02-22 21:06:02 -08:00
parent e21fe3bd79
commit 26e399bc9c
3 changed files with 80 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
internal/rdb/rdb.go
View File

@@ -372,6 +372,7 @@ func (r *RDB) forwardSingle(src, dst string) error {
var writeProcessInfoCmd = redis.NewScript(`
redis.call("SETEX", KEYS[1], ARGV[2], ARGV[3])
redis.call("ZADD", KEYS[2], ARGV[1], KEYS[1])
redis.call("DEL", KEYS[3])
for i = 4, table.getn(ARGV)-1, 2 do
redis.call("HSET", KEYS[3], ARGV[i], ARGV[i+1])
end