mirror of
https://github.com/goharbor/harbor.git
synced 2024-11-26 20:26:13 +01:00
Merge pull request #3954 from ywk253100/180108_repication_fix
Passing tag as a parameter or the value will be overwritten
This commit is contained in:
commit
5456c0bedb
@ -264,8 +264,8 @@ func (ra *RepositoryAPI) Delete() {
|
|||||||
}
|
}
|
||||||
log.Infof("delete tag: %s:%s", repoName, t)
|
log.Infof("delete tag: %s:%s", repoName, t)
|
||||||
|
|
||||||
go func() {
|
go func(tag string) {
|
||||||
image := repoName + ":" + t
|
image := repoName + ":" + tag
|
||||||
err := notifier.Publish(topic.ReplicationEventTopicOnDeletion, notification.OnDeletionNotification{
|
err := notifier.Publish(topic.ReplicationEventTopicOnDeletion, notification.OnDeletionNotification{
|
||||||
Image: image,
|
Image: image,
|
||||||
})
|
})
|
||||||
@ -274,7 +274,7 @@ func (ra *RepositoryAPI) Delete() {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
log.Debugf("the on deletion topic for resource %s published", image)
|
log.Debugf("the on deletion topic for resource %s published", image)
|
||||||
}()
|
}(t)
|
||||||
|
|
||||||
go func(tag string) {
|
go func(tag string) {
|
||||||
if err := dao.AddAccessLog(models.AccessLog{
|
if err := dao.AddAccessLog(models.AccessLog{
|
||||||
|
Loading…
Reference in New Issue
Block a user