feat: implement concurrent workers

.gitignore

@@ -1,2 +1,3 @@
 redis-migrator
 dist
+.test/

cmd/migrate.go

@@ -11,7 +11,9 @@ var migrateCmd = &cobra.Command{
 	Short: "Runs redis-migrator to run migration",
 	Long:  `Runs redis-migrator to run migration`,
 	Run: func(cmd *cobra.Command, args []string) {
-		runMigration()
+		if err := runMigration(); err != nil {
+			panic(err)
+		}
 	},
 }
 
@@ -20,7 +22,7 @@ func init() {
 	rootCmd.AddCommand(migrateCmd)
 }
 
-func runMigration() {
+func runMigration() error {
 	data := config.ParseConfig(configFilePath)
-	migrator.MigrateRedisData(data)
+	return migrator.MigrateRedisData(data)
 }

go.mod

@@ -1,13 +1,17 @@
 module redis-migrator
 
-go 1.15
+go 1.21
 
 require (
-	github.com/go-redis/redis/v8 v8.4.2
 	github.com/gomodule/redigo v1.8.3
-	github.com/mitchellh/mapstructure v1.1.2
 	github.com/sirupsen/logrus v1.7.0
 	github.com/spf13/cobra v1.1.1
 	github.com/spf13/pflag v1.0.5
 	gopkg.in/yaml.v2 v2.3.0
 )
+
+require (
+	github.com/inconshreveable/mousetrap v1.0.0 // indirect
+	github.com/stretchr/testify v1.6.1 // indirect
+	golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f // indirect
+)