support target.db in rump mode

5 years ago · da00771e6b
parent 50e0911261
commit da00771e6b
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))