Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2024-12-24 17:47:46 +01:00
Code Issues Projects Releases Wiki Activity

feature(tag) add a thread pool for tag list

Browse Source 
Signed-off-by: Ziming Zhang <zziming@vmware.com>
This commit is contained in:
Ziming Zhang 2020-09-25 19:34:46 +08:00 committed by Ziming
parent b5a4ebacd6
commit a01a0c1b94
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/core/api/repository.go
View File

@ -649,6 +649,7 @@ func assembleTagsInParallel(client *registry.Repository, projectID int64, reposi
}
}
limit := make(chan bool, 100)
c := make(chan *models.TagResp)
for _, tag := range tags {
go assembleTag(
@ -659,6 +660,7 @@ func assembleTagsInParallel(client *registry.Repository, projectID int64, reposi
tag,
config.WithNotary(),
signatures,
limit,
)
}
result := []*models.TagResp{}
@ -675,7 +677,9 @@ func assembleTagsInParallel(client *registry.Repository, projectID int64, reposi
func assembleTag(c chan *models.TagResp, client *registry.Repository, projectID int64,
repository, tag string, notaryEnabled bool,
signatures map[string][]notarymodel.Target) {
signatures map[string][]notarymodel.Target, limit chan bool) {
limit <- true
defer func() { <-limit }()
item := &models.TagResp{}
// labels
image := fmt.Sprintf("%s:%s", repository, tag)