(ctx context.Context, m blob.Metadata, dst blob.Storage)
| 342 | } |
| 343 | |
| 344 | func syncDeleteBlob(ctx context.Context, m blob.Metadata, dst blob.Storage) error { |
| 345 | err := dst.DeleteBlob(ctx, m.BlobID) |
| 346 | |
| 347 | if errors.Is(err, blob.ErrBlobNotFound) { |
| 348 | return nil |
| 349 | } |
| 350 | |
| 351 | return errors.Wrap(err, "error deleting blob") |
| 352 | } |
| 353 | |
| 354 | func (c *commandRepositorySyncTo) ensureRepositoriesHaveSameFormatBlob(ctx context.Context, src blob.Reader, dst blob.Storage) error { |
| 355 | var srcData gather.WriteBuffer |
no test coverage detected