github/distribution
1
0
Fork 0
mirror of https://github.com/distribution/distribution.git synced 2025-08-09 10:47:30 +00:00
Code Issues Projects Releases Wiki Activity

Merge 10a83bad91 into 523791cb5f

Browse Source
This commit is contained in:
Xiaolei.Liang 2025-04-14 16:08:59 +02:00 committed by GitHub
commit 9967d01852
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 23 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
registry/storage/vacuum.go
View File

@ -91,11 +91,30 @@ func (v Vacuum) RemoveRepository(repoName string) error {
if err != nil {
return err
}
repoDir := path.Join(rootForRepository, repoName)
dcontext.GetLogger(v.ctx).Infof("Deleting repo: %s", repoDir)
err = v.driver.Delete(v.ctx, repoDir)
repoManifestDir := path.Join(rootForRepository, repoName, "_manifests")
dcontext.GetLogger(v.ctx).Infof("Deleting repo: %s", repoManifestDir)
err = v.driver.Delete(v.ctx, repoManifestDir)
if err != nil {
return err
if _, ok := err.(driver.PathNotFoundError); !ok {
return err
}
}
repoLayerDir := path.Join(rootForRepository, repoName, "_layers")
dcontext.GetLogger(v.ctx).Infof("Deleting repo: %s", repoLayerDir)
err = v.driver.Delete(v.ctx, repoLayerDir)
if err != nil {
if _, ok := err.(driver.PathNotFoundError); !ok {
return err
}
}
repoUploadDir := path.Join(rootForRepository, repoName, "_uploads")
dcontext.GetLogger(v.ctx).Infof("Deleting repo: %s", repoUploadDir)
err = v.driver.Delete(v.ctx, repoUploadDir)
if err != nil {
if _, ok := err.(driver.PathNotFoundError); !ok {
return err
}
}
return nil