refactor

Author: zhijian-pro

cmd/sync.go

@@ -143,7 +143,7 @@ Supported storage systems: https://juicefs.com/docs/community/how_to_setup_objec
 				Usage:   "copy symlinks as symlinks",
 			},
 			&cli.Int64Flag{
-				Name:  "limits",
+				Name:  "limit",
 				Usage: "limit the number of objects that will be processed",
 				Value: -1,
 			},

docs/en/reference/command_reference.md

@@ -564,7 +564,7 @@ The order in which `--exclude` and `--include` are set will affect the result. E
 `--links, -l`<br />
 copy symlinks as symlinks (default: false)
 
-` --limits value`<br />
+` --limit value`<br />
 limit the number of objects that will be processed (default: -1)
 
 `--manager value`<br />

docs/zh_cn/reference/command_reference.md

@@ -562,7 +562,7 @@ juicefs sync [command options] SRC DST
 `--links, -l`<br />
 将符号链接复制为符号链接 (默认: false)
 
-` --limits value`<br />
+` --limit value`<br />
 限制将要处理的对象的数量 (默认: -1)
 
 `--manager value`<br />

pkg/sync/config.go

@@ -35,7 +35,7 @@ type Config struct {
 	Exclude     []string
 	Include     []string
 	Links       bool
-	Limits      int64
+	Limit       int64
 	Manager     string
 	Workers     []string
 	BWLimit     int
@@ -65,7 +65,7 @@ func NewConfigFromCli(c *cli.Context) *Config {
 		Exclude:     c.StringSlice("exclude"),
 		Include:     c.StringSlice("include"),
 		Links:       c.Bool("links"),
-		Limits:      c.Int64("limits"),
+		Limit:       c.Int64("limit"),
 		Workers:     c.StringSlice("worker"),
 		Manager:     c.String("manager"),
 		BWLimit:     c.Int("bwlimit"),

pkg/sync/sync.go

@@ -589,11 +589,11 @@ func deleteFromDst(tasks chan<- object.Object, dstobj object.Object, config *Con
 		logger.Debug("Ignore deleting dst directory ", dstobj.Key())
 		return false
 	}
-	if config.Limits != -1 {
-		if config.Limits == 0 {
+	if config.Limit != -1 {
+		if config.Limit == 0 {
 			return true
 		}
-		config.Limits--
+		config.Limit--
 	}
 	tasks <- &withSize{dstobj, markDeleteDst}
 	handled.IncrTotal(1)
@@ -637,11 +637,11 @@ func producer(tasks chan<- object.Object, src, dst object.ObjectStorage, config
 			logger.Debug("Ignore directory ", obj.Key())
 			continue
 		}
-		if config.Limits != -1 {
-			if config.Limits == 0 {
+		if config.Limit != -1 {
+			if config.Limit == 0 {
 				return
 			}
-			config.Limits--
+			config.Limit--
 		}
 		handled.IncrTotal(1)
 

pkg/sync/sync_test.go

@@ -100,7 +100,7 @@ func TestSync(t *testing.T) {
 		Perms:     true,
 		Dry:       false,
 		DeleteSrc: false,
-		Limits:    -1,
+		Limit:     -1,
 		DeleteDst: false,
 		Exclude:   []string{"c*"},
 		Include:   []string{"a[1-9]", "a*"},
@@ -188,7 +188,7 @@ func TestSyncIncludeAndExclude(t *testing.T) {
 		DeleteSrc: false,
 		DeleteDst: false,
 		Verbose:   false,
-		Limits:    -1,
+		Limit:     -1,
 		Quiet:     true,
 		Exclude:   []string{"1"},
 	}
@@ -357,7 +357,7 @@ func TestSyncLink(t *testing.T) {
 		Perms:       true,
 		Links:       true,
 		Quiet:       true,
-		Limits:      -1,
+		Limit:       -1,
 		ForceUpdate: true,
 	}); err != nil {
 		t.Fatalf("sync: %s", err)
@@ -413,7 +413,7 @@ func TestSyncLinkWithOutFollow(t *testing.T) {
 		Perms:       true,
 		Quiet:       true,
 		ForceUpdate: true,
-		Limits:      -1,
+		Limit:       -1,
 	}); err != nil {
 		t.Fatalf("sync: %s", err)
 	}
@@ -447,7 +447,7 @@ func TestSingleLink(t *testing.T) {
 		Perms:       true,
 		Links:       true,
 		Quiet:       true,
-		Limits:      -1,
+		Limit:       -1,
 		ForceUpdate: true,
 	}); err != nil {
 		t.Fatalf("sync: %s", err)
@@ -500,7 +500,7 @@ func TestLimits(t *testing.T) {
 		Perms:   true,
 	}
 	setConfig := func(config *Config, subC subConfig) {
-		config.Limits = subC.limit
+		config.Limit = subC.limit
 		config.DeleteDst = subC.deleteDst
 	}