support target.db in rump mode

5 years ago · e2b6ecd037
parent 047bf142f1
commit e2b6ecd037
1 changed files with 3 additions and 0 deletions
--- a/src/redis-shake/rump.go
+++ b/src/redis-shake/rump.go
@ -339,6 +339,9 @@ func (dre *dbRumperExecutor) writer() {
 			log.Debugf("dbRumper[%v] executor[%v] skip key %s for expired", dre.rumperId, dre.executorId, ele.key)
 			continue
 		}
+		if conf.Options.TargetDB != -1 {
+			ele.db = conf.Options.TargetDB
+		}

 		log.Debugf("dbRumper[%v] executor[%v] restore[%s], length[%v]", dre.rumperId, dre.executorId, ele.key,
 			len(ele.value))