diff options
| author | James Fargher <jfargher@gitlab.com> | 2021-08-25 05:13:35 +0300 |
|---|---|---|
| committer | Patrick Steinhardt <psteinhardt@gitlab.com> | 2021-08-31 09:58:54 +0300 |
| commit | 163fbba78c6225dae58ba9ebd7c181e01dc267be (patch) | |
| tree | 31535e80ad5274af252b0c1b21e1d93db61aaddf /cmd | |
| parent | dfb6159289e75d72806586d86b5eb37cff14f292 (diff) | |
Rename ParallelCreatePipeline to ParallelPipeline
Now that it no longer only handles create, we can make the name more
generic.
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/gitaly-backup/create.go | 2 | ||||
| -rw-r--r-- | cmd/gitaly-backup/restore.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/cmd/gitaly-backup/create.go b/cmd/gitaly-backup/create.go index 3f7833e2d..9dae3d4a5 100644 --- a/cmd/gitaly-backup/create.go +++ b/cmd/gitaly-backup/create.go @@ -51,7 +51,7 @@ func (cmd *createSubcommand) Run(ctx context.Context, stdin io.Reader, stdout io var pipeline backup.Pipeline pipeline = backup.NewLoggingPipeline(log.StandardLogger()) if cmd.parallel > 0 || cmd.parallelStorage > 0 { - pipeline = backup.NewParallelCreatePipeline(pipeline, cmd.parallel, cmd.parallelStorage) + pipeline = backup.NewParallelPipeline(pipeline, cmd.parallel, cmd.parallelStorage) } decoder := json.NewDecoder(stdin) diff --git a/cmd/gitaly-backup/restore.go b/cmd/gitaly-backup/restore.go index 42ce5a087..695e98cfb 100644 --- a/cmd/gitaly-backup/restore.go +++ b/cmd/gitaly-backup/restore.go @@ -53,7 +53,7 @@ func (cmd *restoreSubcommand) Run(ctx context.Context, stdin io.Reader, stdout i var pipeline backup.Pipeline pipeline = backup.NewLoggingPipeline(log.StandardLogger()) if cmd.parallel > 0 || cmd.parallelStorage > 0 { - pipeline = backup.NewParallelCreatePipeline(pipeline, cmd.parallel, cmd.parallelStorage) + pipeline = backup.NewParallelPipeline(pipeline, cmd.parallel, cmd.parallelStorage) } decoder := json.NewDecoder(stdin) |