()
| 221 | } |
| 222 | |
| 223 | func (c *commandRepositorySyncTo) finishSyncProcess() { |
| 224 | if !c.progress.Enabled() { |
| 225 | return |
| 226 | } |
| 227 | |
| 228 | c.out.printStderr("\r%v\n", c.lastSyncProgress) |
| 229 | } |
| 230 | |
| 231 | func (c *commandRepositorySyncTo) runSyncBlobs(ctx context.Context, src blob.Reader, dst blob.Storage, blobsToCopy, blobsToDelete []blob.Metadata, totalBytes int64) error { |
| 232 | eg, ctx := errgroup.WithContext(ctx) |
no test coverage detected